public abstract class AbstractConsulConsumer<C>
extends org.apache.camel.impl.DefaultConsumer
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractConsulConsumer.AbstractWatcher |
Modifier and Type | Field and Description |
---|---|
protected ConsulConfiguration |
configuration |
protected ConsulEndpoint |
endpoint |
protected AtomicReference<BigInteger> |
index |
protected String |
key |
Modifier | Constructor and Description |
---|---|
protected |
AbstractConsulConsumer(ConsulEndpoint endpoint,
ConsulConfiguration configuration,
org.apache.camel.Processor processor,
Function<com.orbitz.consul.Consul,C> clientSupplier) |
Modifier and Type | Method and Description |
---|---|
protected abstract Runnable |
createWatcher(C client) |
protected void |
doStart() |
protected void |
doStop() |
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
protected final ConsulEndpoint endpoint
protected final ConsulConfiguration configuration
protected final String key
protected final AtomicReference<BigInteger> index
protected AbstractConsulConsumer(ConsulEndpoint endpoint, ConsulConfiguration configuration, org.apache.camel.Processor processor, Function<com.orbitz.consul.Consul,C> clientSupplier)
Apache Camel