public class MicrometerRoutePolicy
extends org.apache.camel.support.RoutePolicySupport
implements org.apache.camel.NonManagedService
RoutePolicy
which gathers statistics and reports them using MeterRegistry
.
The metrics is reported in JMX by default, but this can be configured.Constructor and Description |
---|
MicrometerRoutePolicy() |
Modifier and Type | Method and Description |
---|---|
TimeUnit |
getDurationUnit() |
io.micrometer.core.instrument.MeterRegistry |
getMeterRegistry() |
MicrometerRoutePolicyNamingStrategy |
getNamingStrategy() |
boolean |
isPrettyPrint() |
void |
onExchangeBegin(org.apache.camel.Route route,
org.apache.camel.Exchange exchange) |
void |
onExchangeDone(org.apache.camel.Route route,
org.apache.camel.Exchange exchange) |
void |
onInit(org.apache.camel.Route route) |
void |
setDurationUnit(TimeUnit durationUnit) |
void |
setMeterRegistry(io.micrometer.core.instrument.MeterRegistry meterRegistry) |
void |
setNamingStrategy(MicrometerRoutePolicyNamingStrategy namingStrategy) |
void |
setPrettyPrint(boolean prettyPrint) |
doStart, doStop, getExceptionHandler, handleException, onRemove, onResume, onStart, onStop, onSuspend, resumeOrStartConsumer, resumeRoute, setExceptionHandler, startConsumer, startRoute, stopConsumer, stopRoute, stopRoute, stopRouteAsync, suspendOrStopConsumer, suspendRoute, suspendRoute
public io.micrometer.core.instrument.MeterRegistry getMeterRegistry()
public void setMeterRegistry(io.micrometer.core.instrument.MeterRegistry meterRegistry)
public boolean isPrettyPrint()
public void setPrettyPrint(boolean prettyPrint)
public TimeUnit getDurationUnit()
public void setDurationUnit(TimeUnit durationUnit)
public MicrometerRoutePolicyNamingStrategy getNamingStrategy()
public void setNamingStrategy(MicrometerRoutePolicyNamingStrategy namingStrategy)
public void onInit(org.apache.camel.Route route)
onInit
in interface org.apache.camel.spi.RoutePolicy
onInit
in class org.apache.camel.support.RoutePolicySupport
public void onExchangeBegin(org.apache.camel.Route route, org.apache.camel.Exchange exchange)
onExchangeBegin
in interface org.apache.camel.spi.RoutePolicy
onExchangeBegin
in class org.apache.camel.support.RoutePolicySupport
public void onExchangeDone(org.apache.camel.Route route, org.apache.camel.Exchange exchange)
onExchangeDone
in interface org.apache.camel.spi.RoutePolicy
onExchangeDone
in class org.apache.camel.support.RoutePolicySupport
Apache Camel