public class MicrometerMessageHistoryFactory
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.CamelContextAware, org.apache.camel.StaticService, org.apache.camel.NonManagedService, org.apache.camel.spi.MessageHistoryFactory
MicrometerMessageHistory
as message history implementation.Constructor and Description |
---|
MicrometerMessageHistoryFactory() |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
org.apache.camel.CamelContext |
getCamelContext() |
TimeUnit |
getDurationUnit() |
io.micrometer.core.instrument.MeterRegistry |
getMeterRegistry() |
MicrometerMessageHistoryNamingStrategy |
getNamingStrategy() |
boolean |
isPrettyPrint() |
org.apache.camel.MessageHistory |
newMessageHistory(String routeId,
org.apache.camel.NamedNode namedNode,
Date date)
Deprecated.
|
org.apache.camel.MessageHistory |
newMessageHistory(String routeId,
org.apache.camel.NamedNode namedNode,
long timestamp) |
void |
setCamelContext(org.apache.camel.CamelContext camelContext) |
void |
setDurationUnit(TimeUnit durationUnit)
Sets the time unit to use for timing the duration of processing a message in the route
|
void |
setMeterRegistry(io.micrometer.core.instrument.MeterRegistry meterRegistry)
To use a specific
MeterRegistry instance. |
void |
setNamingStrategy(MicrometerMessageHistoryNamingStrategy namingStrategy)
Sets the naming strategy for message history meter names
|
void |
setPrettyPrint(boolean prettyPrint)
Whether to use pretty print when outputting JSon
|
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public org.apache.camel.CamelContext getCamelContext()
getCamelContext
in interface org.apache.camel.CamelContextAware
public void setCamelContext(org.apache.camel.CamelContext camelContext)
setCamelContext
in interface org.apache.camel.CamelContextAware
public io.micrometer.core.instrument.MeterRegistry getMeterRegistry()
public void setMeterRegistry(io.micrometer.core.instrument.MeterRegistry meterRegistry)
MeterRegistry
instance.
If no instance has been configured, then Camel will create a shared instance to be used.public boolean isPrettyPrint()
public void setPrettyPrint(boolean prettyPrint)
public TimeUnit getDurationUnit()
public void setDurationUnit(TimeUnit durationUnit)
public MicrometerMessageHistoryNamingStrategy getNamingStrategy()
public void setNamingStrategy(MicrometerMessageHistoryNamingStrategy namingStrategy)
@Deprecated public org.apache.camel.MessageHistory newMessageHistory(String routeId, org.apache.camel.NamedNode namedNode, Date date)
newMessageHistory
in interface org.apache.camel.spi.MessageHistoryFactory
public org.apache.camel.MessageHistory newMessageHistory(String routeId, org.apache.camel.NamedNode namedNode, long timestamp)
newMessageHistory
in interface org.apache.camel.spi.MessageHistoryFactory
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
protected void doStop()
doStop
in class org.apache.camel.support.ServiceSupport
Apache Camel