public abstract class AbstractMetricsProducer
extends org.apache.camel.impl.DefaultProducer
Modifier and Type | Field and Description |
---|---|
static String |
HEADER_PATTERN |
Constructor and Description |
---|
AbstractMetricsProducer(MetricsEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
clearMetricsHeaders(org.apache.camel.Message in) |
protected abstract void |
doProcess(org.apache.camel.Exchange exchange,
MetricsEndpoint endpoint,
com.codahale.metrics.MetricRegistry registry,
String metricsName) |
MetricsEndpoint |
getEndpoint() |
Long |
getLongHeader(org.apache.camel.Message in,
String header,
Long defaultValue) |
String |
getMetricsName(org.apache.camel.Message in,
String defaultValue) |
String |
getStringHeader(org.apache.camel.Message in,
String header,
String defaultValue) |
void |
process(org.apache.camel.Exchange exchange) |
createExchange, createExchange, createExchange, doStart, doStop, isSingleton, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public static final String HEADER_PATTERN
public AbstractMetricsProducer(MetricsEndpoint endpoint)
public MetricsEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultProducer
protected abstract void doProcess(org.apache.camel.Exchange exchange, MetricsEndpoint endpoint, com.codahale.metrics.MetricRegistry registry, String metricsName) throws Exception
Exception
public String getStringHeader(org.apache.camel.Message in, String header, String defaultValue)
public Long getLongHeader(org.apache.camel.Message in, String header, Long defaultValue)
protected boolean clearMetricsHeaders(org.apache.camel.Message in)
Apache Camel