@ManagedResource(description="Route policy using Infinispan as clustered lock")
public class InfinispanRoutePolicy
extends org.apache.camel.support.RoutePolicySupport
implements org.apache.camel.CamelContextAware
Constructor and Description |
---|
InfinispanRoutePolicy(InfinispanConfiguration configuration) |
InfinispanRoutePolicy(InfinispanManager manager) |
InfinispanRoutePolicy(InfinispanManager manager,
String lockKey,
String lockValue) |
Modifier and Type | Method and Description |
---|---|
void |
doShutdown() |
org.apache.camel.CamelContext |
getCamelContext() |
long |
getLifespan() |
TimeUnit |
getLifespanTimeUnit() |
String |
getLockKey() |
String |
getLockMapName() |
String |
getLockValue() |
boolean |
isLeader() |
boolean |
isShouldStopRoute() |
void |
onInit(org.apache.camel.Route route) |
void |
setCamelContext(org.apache.camel.CamelContext camelContext) |
void |
setLifespan(long lifespan) |
void |
setLifespan(long lifespan,
TimeUnit lifespanTimeUnit) |
void |
setLifespanTimeUnit(TimeUnit lifespanTimeUnit) |
void |
setLockKey(String lockKey) |
void |
setLockMapName(String lockMapName) |
void |
setLockValue(String lockValue) |
void |
setShouldStopRoute(boolean shouldStopRoute) |
static InfinispanRoutePolicy |
withManager(org.infinispan.commons.api.BasicCacheContainer cacheContainer) |
doStart, doStop, getExceptionHandler, handleException, onExchangeBegin, onExchangeDone, onRemove, onResume, onStart, onStop, onSuspend, resumeOrStartConsumer, resumeRoute, setExceptionHandler, startConsumer, startRoute, stopConsumer, stopRoute, stopRoute, stopRouteAsync, suspendOrStopConsumer, suspendRoute, suspendRoute
public InfinispanRoutePolicy(InfinispanConfiguration configuration)
public InfinispanRoutePolicy(InfinispanManager manager)
public InfinispanRoutePolicy(InfinispanManager manager, String lockKey, String lockValue)
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 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 doShutdown()
doShutdown
in class org.apache.camel.support.ServiceSupport
@ManagedAttribute(description="Whether to stop route when starting up and failed to become master") public boolean isShouldStopRoute()
public void setShouldStopRoute(boolean shouldStopRoute)
@ManagedAttribute(description="The lock map name") public String getLockMapName()
public void setLockMapName(String lockMapName)
@ManagedAttribute(description="The lock key") public String getLockKey()
public void setLockKey(String lockKey)
@ManagedAttribute(description="The lock value") public String getLockValue()
public void setLockValue(String lockValue)
@ManagedAttribute(description="The key lifespan for the lock") public long getLifespan()
public void setLifespan(long lifespan)
public void setLifespan(long lifespan, TimeUnit lifespanTimeUnit)
@ManagedAttribute(description="The key lifespan time unit for the lock") public TimeUnit getLifespanTimeUnit()
public void setLifespanTimeUnit(TimeUnit lifespanTimeUnit)
@ManagedAttribute(description="Is this route the master or a slave") public boolean isLeader()
public static InfinispanRoutePolicy withManager(org.infinispan.commons.api.BasicCacheContainer cacheContainer)
Apache Camel