public class ConsulKeyValueConsumer extends AbstractConsulConsumer<com.orbitz.consul.KeyValueClient>
AbstractConsulConsumer.AbstractWatcher
configuration, endpoint, index, key
Constructor and Description |
---|
ConsulKeyValueConsumer(ConsulEndpoint endpoint,
ConsulConfiguration configuration,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
protected Runnable |
createWatcher(com.orbitz.consul.KeyValueClient client) |
doStart, 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
public ConsulKeyValueConsumer(ConsulEndpoint endpoint, ConsulConfiguration configuration, org.apache.camel.Processor processor)
protected Runnable createWatcher(com.orbitz.consul.KeyValueClient client) throws Exception
createWatcher
in class AbstractConsulConsumer<com.orbitz.consul.KeyValueClient>
Exception
Apache Camel