public class EtcdRoutePolicy
extends org.apache.camel.support.RoutePolicySupport
implements mousio.client.promises.ResponsePromise.IsSimplePromiseResponseHandler<mousio.etcd4j.responses.EtcdKeysResponse>, org.apache.camel.NonManagedService
Constructor and Description |
---|
EtcdRoutePolicy() |
EtcdRoutePolicy(mousio.etcd4j.EtcdClient client) |
EtcdRoutePolicy(mousio.etcd4j.EtcdClient client,
boolean managedClient) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
mousio.etcd4j.EtcdClient |
getClient() |
String |
getServiceName() |
String |
getServicePath() |
int |
getTtl() |
int |
getWatchTimeout() |
boolean |
isShouldStopConsumer() |
void |
onResponse(mousio.client.promises.ResponsePromise<mousio.etcd4j.responses.EtcdKeysResponse> promise) |
void |
onStart(org.apache.camel.Route route) |
void |
onStop(org.apache.camel.Route route) |
void |
onSuspend(org.apache.camel.Route route) |
protected void |
setLeader(boolean isLeader) |
void |
setServiceName(String serviceName) |
void |
setServicePath(String servicePath) |
void |
setShouldStopConsumer(boolean shouldStopConsumer) |
void |
setTtl(int ttl) |
void |
setWatchTimeout(int watchTimeout) |
getExceptionHandler, handleException, onExchangeBegin, onExchangeDone, onInit, onRemove, onResume, resumeRoute, setExceptionHandler, startConsumer, startRoute, stopConsumer, stopRoute, stopRoute, suspendRoute, suspendRoute
public EtcdRoutePolicy()
public EtcdRoutePolicy(mousio.etcd4j.EtcdClient client)
public EtcdRoutePolicy(mousio.etcd4j.EtcdClient client, boolean managedClient)
public void onStart(org.apache.camel.Route route)
onStart
in interface org.apache.camel.spi.RoutePolicy
onStart
in class org.apache.camel.support.RoutePolicySupport
public void onStop(org.apache.camel.Route route)
onStop
in interface org.apache.camel.spi.RoutePolicy
onStop
in class org.apache.camel.support.RoutePolicySupport
public void onSuspend(org.apache.camel.Route route)
onSuspend
in interface org.apache.camel.spi.RoutePolicy
onSuspend
in class org.apache.camel.support.RoutePolicySupport
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.RoutePolicySupport
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.support.RoutePolicySupport
Exception
protected void setLeader(boolean isLeader)
public mousio.etcd4j.EtcdClient getClient()
public String getServiceName()
public void setServiceName(String serviceName)
public String getServicePath()
public void setServicePath(String servicePath)
public int getTtl()
public void setTtl(int ttl)
public int getWatchTimeout()
public void setWatchTimeout(int watchTimeout)
public boolean isShouldStopConsumer()
public void setShouldStopConsumer(boolean shouldStopConsumer)
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