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