public class EtcdWatchConsumer extends AbstractEtcdConsumer implements mousio.client.promises.ResponsePromise.IsSimplePromiseResponseHandler<mousio.etcd4j.responses.EtcdKeysResponse>
Constructor and Description |
---|
EtcdWatchConsumer(EtcdWatchEndpoint endpoint,
org.apache.camel.Processor processor,
EtcdConfiguration configuration,
EtcdNamespace namespace,
String path) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
void |
onResponse(mousio.client.promises.ResponsePromise<mousio.etcd4j.responses.EtcdKeysResponse> promise) |
getClient, getConfiguration, getNamespace, getPath
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 EtcdWatchConsumer(EtcdWatchEndpoint endpoint, org.apache.camel.Processor processor, EtcdConfiguration configuration, EtcdNamespace namespace, String path)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void doStop() throws Exception
doStop
in class AbstractEtcdConsumer
Exception
public void onResponse(mousio.client.promises.ResponsePromise<mousio.etcd4j.responses.EtcdKeysResponse> promise)
onResponse
in interface mousio.client.promises.ResponsePromise.IsSimplePromiseResponseHandler<mousio.etcd4j.responses.EtcdKeysResponse>
Apache Camel