public class EtcdStatsConsumer extends AbstractEtcdPollingConsumer
Constructor and Description |
---|
EtcdStatsConsumer(EtcdStatsEndpoint endpoint,
org.apache.camel.Processor processor,
EtcdConfiguration configuration,
EtcdNamespace namespace,
String path) |
Modifier and Type | Method and Description |
---|---|
EtcdStatsEndpoint |
getEndpoint() |
protected int |
poll() |
doStop, getClient, getConfiguration, getNamespace, getPath
afterPoll, beforePoll, doShutdown, doStart, doSuspend, getBackoffCounter, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, isGreedy, isPollAllowed, isPolling, isSchedulerStarted, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, onInit, processEmptyMessage, run, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startScheduler
createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public EtcdStatsConsumer(EtcdStatsEndpoint endpoint, org.apache.camel.Processor processor, EtcdConfiguration configuration, EtcdNamespace namespace, String path)
public EtcdStatsEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.EndpointAware
getEndpoint
in class org.apache.camel.impl.DefaultConsumer
Apache Camel