public class ClusteredSingletonLifecycleStrategy extends Object implements org.apache.camel.spi.LifecycleStrategy, io.fabric8.groups.GroupListener<CamelNodeState>, Callable<org.apache.curator.framework.CuratorFramework>
Modifier and Type | Field and Description |
---|---|
static org.apache.commons.logging.Log |
LOG |
Constructor and Description |
---|
ClusteredSingletonLifecycleStrategy() |
Modifier and Type | Method and Description |
---|---|
org.apache.curator.framework.CuratorFramework |
call() |
org.apache.curator.framework.CuratorFramework |
getCurator() |
String |
getGroupName() |
void |
groupEvent(io.fabric8.groups.Group<CamelNodeState> group,
io.fabric8.groups.GroupListener.GroupEvent event) |
void |
onComponentAdd(String s,
org.apache.camel.Component component) |
void |
onComponentRemove(String s,
org.apache.camel.Component component) |
void |
onContextStart(org.apache.camel.CamelContext camelContext) |
void |
onContextStop(org.apache.camel.CamelContext camelContext) |
void |
onEndpointAdd(org.apache.camel.Endpoint endpoint) |
void |
onEndpointRemove(org.apache.camel.Endpoint endpoint) |
void |
onErrorHandlerAdd(org.apache.camel.spi.RouteContext routeContext,
org.apache.camel.Processor processor,
org.apache.camel.builder.ErrorHandlerBuilder errorHandlerBuilder) |
void |
onErrorHandlerAdd(org.apache.camel.spi.RouteContext routeContext,
org.apache.camel.Processor processor,
org.apache.camel.ErrorHandlerFactory errorHandlerFactory) |
void |
onErrorHandlerRemove(org.apache.camel.spi.RouteContext routeContext,
org.apache.camel.Processor errorHandler,
org.apache.camel.ErrorHandlerFactory errorHandlerBuilder) |
void |
onRouteContextCreate(org.apache.camel.spi.RouteContext routeContext) |
void |
onRoutesAdd(Collection<org.apache.camel.Route> routes) |
void |
onRoutesRemove(Collection<org.apache.camel.Route> routes) |
void |
onServiceAdd(org.apache.camel.CamelContext camelContext,
org.apache.camel.Service service,
org.apache.camel.Route route) |
void |
onServiceRemove(org.apache.camel.CamelContext camelContext,
org.apache.camel.Service service,
org.apache.camel.Route route) |
void |
onThreadPoolAdd(org.apache.camel.CamelContext camelContext,
ThreadPoolExecutor threadPoolExecutor,
String s,
String s1,
String s2,
String s3) |
void |
onThreadPoolRemove(org.apache.camel.CamelContext camelContext,
ThreadPoolExecutor threadPoolExecutor) |
void |
setCurator(org.apache.curator.framework.CuratorFramework curator) |
void |
setGroupName(String groupName) |
void |
start() |
void |
stop() |
public org.apache.curator.framework.CuratorFramework call() throws Exception
public void stop()
public void groupEvent(io.fabric8.groups.Group<CamelNodeState> group, io.fabric8.groups.GroupListener.GroupEvent event)
groupEvent
in interface io.fabric8.groups.GroupListener<CamelNodeState>
public void onContextStart(org.apache.camel.CamelContext camelContext) throws org.apache.camel.VetoCamelContextStartException
onContextStart
in interface org.apache.camel.spi.LifecycleStrategy
org.apache.camel.VetoCamelContextStartException
public void onContextStop(org.apache.camel.CamelContext camelContext)
onContextStop
in interface org.apache.camel.spi.LifecycleStrategy
public void onComponentAdd(String s, org.apache.camel.Component component)
onComponentAdd
in interface org.apache.camel.spi.LifecycleStrategy
public void onComponentRemove(String s, org.apache.camel.Component component)
onComponentRemove
in interface org.apache.camel.spi.LifecycleStrategy
public void onEndpointAdd(org.apache.camel.Endpoint endpoint)
onEndpointAdd
in interface org.apache.camel.spi.LifecycleStrategy
public void onEndpointRemove(org.apache.camel.Endpoint endpoint)
onEndpointRemove
in interface org.apache.camel.spi.LifecycleStrategy
public void onServiceAdd(org.apache.camel.CamelContext camelContext, org.apache.camel.Service service, org.apache.camel.Route route)
onServiceAdd
in interface org.apache.camel.spi.LifecycleStrategy
public void onServiceRemove(org.apache.camel.CamelContext camelContext, org.apache.camel.Service service, org.apache.camel.Route route)
onServiceRemove
in interface org.apache.camel.spi.LifecycleStrategy
public void onRoutesAdd(Collection<org.apache.camel.Route> routes)
onRoutesAdd
in interface org.apache.camel.spi.LifecycleStrategy
public void onRoutesRemove(Collection<org.apache.camel.Route> routes)
onRoutesRemove
in interface org.apache.camel.spi.LifecycleStrategy
public void onRouteContextCreate(org.apache.camel.spi.RouteContext routeContext)
onRouteContextCreate
in interface org.apache.camel.spi.LifecycleStrategy
public void onErrorHandlerAdd(org.apache.camel.spi.RouteContext routeContext, org.apache.camel.Processor processor, org.apache.camel.ErrorHandlerFactory errorHandlerFactory)
onErrorHandlerAdd
in interface org.apache.camel.spi.LifecycleStrategy
public void onErrorHandlerAdd(org.apache.camel.spi.RouteContext routeContext, org.apache.camel.Processor processor, org.apache.camel.builder.ErrorHandlerBuilder errorHandlerBuilder)
public void onErrorHandlerRemove(org.apache.camel.spi.RouteContext routeContext, org.apache.camel.Processor errorHandler, org.apache.camel.ErrorHandlerFactory errorHandlerBuilder)
onErrorHandlerRemove
in interface org.apache.camel.spi.LifecycleStrategy
public void onThreadPoolAdd(org.apache.camel.CamelContext camelContext, ThreadPoolExecutor threadPoolExecutor, String s, String s1, String s2, String s3)
onThreadPoolAdd
in interface org.apache.camel.spi.LifecycleStrategy
public void onThreadPoolRemove(org.apache.camel.CamelContext camelContext, ThreadPoolExecutor threadPoolExecutor)
onThreadPoolRemove
in interface org.apache.camel.spi.LifecycleStrategy
public String getGroupName()
public void setGroupName(String groupName)
public org.apache.curator.framework.CuratorFramework getCurator()
public void setCurator(org.apache.curator.framework.CuratorFramework curator)
Copyright © 2011–2014 Red Hat. All rights reserved.