public class HazelcastRoutePolicy
extends org.apache.camel.support.RoutePolicySupport
implements org.apache.camel.NonManagedService
Constructor and Description |
---|
HazelcastRoutePolicy() |
HazelcastRoutePolicy(com.hazelcast.core.HazelcastInstance instance) |
HazelcastRoutePolicy(com.hazelcast.core.HazelcastInstance instance,
boolean managedInstance) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart() |
protected void |
doStop() |
String |
getLockKey() |
String |
getLockMapName() |
String |
getLockValue() |
long |
getTryLockTimeout() |
TimeUnit |
getTryLockTimeoutUnit() |
boolean |
isLeader() |
boolean |
isShouldStopConsumer() |
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 |
setLockKey(String lockKey) |
void |
setLockMapName(String lockMapName) |
void |
setLockValue(String lockValue) |
void |
setShouldStopConsumer(boolean shouldStopConsumer) |
void |
setTryLockTimeout(long tryLockTimeout) |
void |
setTryLockTimeout(long tryLockTimeout,
TimeUnit tryLockTimeoutUnit) |
void |
setTryLockTimeoutUnit(TimeUnit tryLockTimeoutUnit) |
getExceptionHandler, handleException, onExchangeBegin, onExchangeDone, onInit, onRemove, onResume, resumeRoute, setExceptionHandler, startConsumer, startRoute, stopConsumer, stopRoute, stopRoute, suspendRoute, suspendRoute
public HazelcastRoutePolicy()
public HazelcastRoutePolicy(com.hazelcast.core.HazelcastInstance instance)
public HazelcastRoutePolicy(com.hazelcast.core.HazelcastInstance instance, boolean managedInstance)
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 String getLockMapName()
public void setLockMapName(String lockMapName)
public boolean isShouldStopConsumer()
public void setShouldStopConsumer(boolean shouldStopConsumer)
public String getLockKey()
public void setLockKey(String lockKey)
public String getLockValue()
public void setLockValue(String lockValue)
public long getTryLockTimeout()
public void setTryLockTimeout(long tryLockTimeout)
public void setTryLockTimeout(long tryLockTimeout, TimeUnit tryLockTimeoutUnit)
public TimeUnit getTryLockTimeoutUnit()
public void setTryLockTimeoutUnit(TimeUnit tryLockTimeoutUnit)
public boolean isLeader()
Apache Camel