public class ConsulRoutePolicy
extends org.apache.camel.support.RoutePolicySupport
implements org.apache.camel.NonManagedService
Constructor and Description |
---|
ConsulRoutePolicy() |
ConsulRoutePolicy(com.orbitz.consul.Consul consul) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
com.orbitz.consul.Consul |
getConsul() |
ExecutorService |
getExecutorService() |
int |
getLockDelay() |
String |
getServiceName() |
int |
getTtl() |
boolean |
isShouldStopConsumer() |
void |
onStart(org.apache.camel.Route route) |
void |
onStop(org.apache.camel.Route route) |
void |
onSuspend(org.apache.camel.Route route) |
void |
setExecutorService(ExecutorService executorService) |
protected void |
setLeader(boolean isLeader) |
void |
setLockDelay(int lockDelay) |
void |
setServiceName(String serviceName) |
void |
setShouldStopConsumer(boolean shouldStopConsumer) |
void |
setTtl(int ttl) |
getExceptionHandler, handleException, onExchangeBegin, onExchangeDone, onInit, onRemove, onResume, resumeRoute, setExceptionHandler, startConsumer, startRoute, stopConsumer, stopRoute, stopRoute, suspendRoute, suspendRoute
public ConsulRoutePolicy()
public ConsulRoutePolicy(com.orbitz.consul.Consul consul)
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 com.orbitz.consul.Consul getConsul()
public String getServiceName()
public void setServiceName(String serviceName)
public int getTtl()
public void setTtl(int ttl)
public int getLockDelay()
public void setLockDelay(int lockDelay)
public ExecutorService getExecutorService()
public void setExecutorService(ExecutorService executorService)
public boolean isShouldStopConsumer()
public void setShouldStopConsumer(boolean shouldStopConsumer)
Apache Camel