ConsulClusterService
and ClusteredRoutePolicy
instead.@Deprecated @ManagedResource(description="Route policy using Consul as clustered lock") public final class ConsulRoutePolicy extends org.apache.camel.support.RoutePolicySupport implements org.apache.camel.CamelContextAware
Constructor and Description |
---|
ConsulRoutePolicy()
Deprecated.
|
ConsulRoutePolicy(ConsulConfiguration configuration)
Deprecated.
|
ConsulRoutePolicy(String consulUrl)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
doStart()
Deprecated.
|
protected void |
doStop()
Deprecated.
|
org.apache.camel.CamelContext |
getCamelContext()
Deprecated.
|
com.orbitz.consul.Consul |
getConsul()
Deprecated.
|
String |
getConsulUrl()
Deprecated.
|
String |
getEndpointUrl()
Deprecated.
|
int |
getLockDelay()
Deprecated.
|
String |
getRouteId()
Deprecated.
|
String |
getServiceName()
Deprecated.
|
int |
getTtl()
Deprecated.
|
boolean |
isLeader()
Deprecated.
|
boolean |
isShouldStopConsumer()
Deprecated.
|
void |
onInit(org.apache.camel.Route route)
Deprecated.
|
void |
onStart(org.apache.camel.Route route)
Deprecated.
|
void |
onStop(org.apache.camel.Route route)
Deprecated.
|
void |
onSuspend(org.apache.camel.Route route)
Deprecated.
|
void |
setCamelContext(org.apache.camel.CamelContext camelContext)
Deprecated.
|
void |
setConsulUrl(String consulUrl)
Deprecated.
|
protected void |
setLeader(boolean isLeader)
Deprecated.
|
void |
setLockDelay(int lockDelay)
Deprecated.
|
void |
setServiceName(String serviceName)
Deprecated.
|
void |
setShouldStopConsumer(boolean shouldStopConsumer)
Deprecated.
|
void |
setTtl(int ttl)
Deprecated.
|
getExceptionHandler, handleException, onExchangeBegin, onExchangeDone, onRemove, onResume, resumeOrStartConsumer, resumeRoute, setExceptionHandler, startConsumer, startRoute, stopConsumer, stopRoute, stopRoute, stopRouteAsync, suspendOrStopConsumer, suspendRoute, suspendRoute
public ConsulRoutePolicy()
public ConsulRoutePolicy(String consulUrl)
public ConsulRoutePolicy(ConsulConfiguration configuration) throws Exception
Exception
public org.apache.camel.CamelContext getCamelContext()
getCamelContext
in interface org.apache.camel.CamelContextAware
public void setCamelContext(org.apache.camel.CamelContext camelContext)
setCamelContext
in interface org.apache.camel.CamelContextAware
public String getConsulUrl()
public void setConsulUrl(String consulUrl)
public void onInit(org.apache.camel.Route route)
onInit
in interface org.apache.camel.spi.RoutePolicy
onInit
in class org.apache.camel.support.RoutePolicySupport
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)
@ManagedAttribute(description="The route id") public String getRouteId()
@ManagedAttribute(description="The consumer endpoint", mask=true) public String getEndpointUrl()
public com.orbitz.consul.Consul getConsul()
@ManagedAttribute(description="The consul service name") public String getServiceName()
public void setServiceName(String serviceName)
@ManagedAttribute(description="The time to live (seconds)") public int getTtl()
public void setTtl(int ttl)
@ManagedAttribute(description="The lock delay (seconds)") public int getLockDelay()
public void setLockDelay(int lockDelay)
@ManagedAttribute(description="Whether to stop consumer when starting up and failed to become master") public boolean isShouldStopConsumer()
public void setShouldStopConsumer(boolean shouldStopConsumer)
@ManagedAttribute(description="Is this route the master or a slave") public boolean isLeader()
Apache Camel