public abstract class AbstractMicrometerProducer<T extends io.micrometer.core.instrument.Meter>
extends org.apache.camel.impl.DefaultProducer
Constructor and Description |
---|
AbstractMicrometerProducer(MicrometerEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
clearMetricsHeaders(org.apache.camel.Message in) |
protected abstract void |
doProcess(org.apache.camel.Exchange exchange,
MicrometerEndpoint endpoint,
T meter) |
protected void |
doProcess(org.apache.camel.Exchange exchange,
String name,
Iterable<io.micrometer.core.instrument.Tag> tags) |
protected Double |
getDoubleHeader(org.apache.camel.Message in,
String header,
Double defaultValue) |
MicrometerEndpoint |
getEndpoint() |
protected T |
getOrRegisterMeter(String name,
Iterable<io.micrometer.core.instrument.Tag> tags) |
protected String |
getStringHeader(org.apache.camel.Message in,
String header,
String defaultValue) |
protected Iterable<io.micrometer.core.instrument.Tag> |
getTagHeader(org.apache.camel.Message in,
String header,
Iterable<io.micrometer.core.instrument.Tag> defaultTags) |
void |
process(org.apache.camel.Exchange exchange) |
protected abstract Function<io.micrometer.core.instrument.MeterRegistry,T> |
registrar(String name,
Iterable<io.micrometer.core.instrument.Tag> tags) |
protected <C> C |
simple(org.apache.camel.Exchange exchange,
String expression,
Class<C> clazz) |
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 AbstractMicrometerProducer(MicrometerEndpoint endpoint)
public MicrometerEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultProducer
public void process(org.apache.camel.Exchange exchange)
protected abstract Function<io.micrometer.core.instrument.MeterRegistry,T> registrar(String name, Iterable<io.micrometer.core.instrument.Tag> tags)
protected void doProcess(org.apache.camel.Exchange exchange, String name, Iterable<io.micrometer.core.instrument.Tag> tags)
protected T getOrRegisterMeter(String name, Iterable<io.micrometer.core.instrument.Tag> tags)
protected abstract void doProcess(org.apache.camel.Exchange exchange, MicrometerEndpoint endpoint, T meter)
protected <C> C simple(org.apache.camel.Exchange exchange, String expression, Class<C> clazz)
protected String getStringHeader(org.apache.camel.Message in, String header, String defaultValue)
protected Double getDoubleHeader(org.apache.camel.Message in, String header, Double defaultValue)
protected Iterable<io.micrometer.core.instrument.Tag> getTagHeader(org.apache.camel.Message in, String header, Iterable<io.micrometer.core.instrument.Tag> defaultTags)
protected boolean clearMetricsHeaders(org.apache.camel.Message in)
Apache Camel