public class DefaultManagementLifecycleStrategy extends ServiceSupport implements LifecycleStrategy, CamelContextAware
ManagementStrategy.ManagementStrategyshutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
DefaultManagementLifecycleStrategy() |
DefaultManagementLifecycleStrategy(CamelContext camelContext) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doStart()
Implementations override this method to support customized start/stop.
|
protected void |
doStop()
Implementations override this method to support customized start/stop.
|
CamelContext |
getCamelContext()
Get the
CamelContext |
protected void |
manageObject(Object me)
Strategy for managing the object
|
void |
onComponentAdd(String name,
Component component)
Notification on adding an
Component. |
void |
onComponentRemove(String name,
Component component)
Notification on removing an
Component. |
void |
onContextStart(CamelContext context)
Notification on starting a
CamelContext. |
void |
onContextStop(CamelContext context)
Notification on stopping a
CamelContext. |
void |
onEndpointAdd(Endpoint endpoint)
If the endpoint is an instance of ManagedResource then register it with the
mbean server, if it is not then wrap the endpoint in a
ManagedEndpoint and
register that with the mbean server. |
void |
onEndpointRemove(Endpoint endpoint)
Notification on removing an
Endpoint. |
void |
onErrorHandlerAdd(RouteContext routeContext,
Processor errorHandler,
ErrorHandlerFactory errorHandlerBuilder)
Notification on adding error handler.
|
void |
onErrorHandlerRemove(RouteContext routeContext,
Processor errorHandler,
ErrorHandlerFactory errorHandlerBuilder)
Notification on removing error handler.
|
void |
onRouteContextCreate(RouteContext routeContext)
Notification on adding
RouteContext(s). |
void |
onRoutesAdd(Collection<Route> routes)
Notification on adding
Route(s). |
void |
onRoutesRemove(Collection<Route> routes)
Notification on removing
Route(s). |
void |
onServiceAdd(CamelContext context,
Service service,
Route route)
Notification on adding a
Service. |
void |
onServiceRemove(CamelContext context,
Service service,
Route route)
Notification on removing a
Service. |
void |
onThreadPoolAdd(CamelContext camelContext,
ThreadPoolExecutor threadPool,
String id,
String sourceId,
String routeId,
String threadPoolProfileId)
Notification on adding a thread pool.
|
void |
onThreadPoolRemove(CamelContext camelContext,
ThreadPoolExecutor threadPool)
Notification on removing a thread pool.
|
protected boolean |
registerProcessor(ProcessorDefinition<?> processor)
Should the given processor be registered.
|
void |
setCamelContext(CamelContext camelContext)
Injects the
CamelContext |
protected boolean |
shouldRegister(Object service,
Route route)
Whether or not to register the mbean.
|
protected void |
unmanageObject(Object me)
Un-manages the object.
|
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic DefaultManagementLifecycleStrategy()
public DefaultManagementLifecycleStrategy(CamelContext camelContext)
public CamelContext getCamelContext()
CamelContextAwareCamelContextgetCamelContext in interface CamelContextAwarepublic void setCamelContext(CamelContext camelContext)
CamelContextAwareCamelContextsetCamelContext in interface CamelContextAwarecamelContext - the Camel contextpublic void onContextStart(CamelContext context) throws VetoCamelContextStartException
LifecycleStrategyCamelContext.onContextStart in interface LifecycleStrategycontext - the camel contextVetoCamelContextStartException - can be thrown to veto starting CamelContext.
Any other runtime exceptions will be logged at WARN level by Camel will continue starting itself.public void onContextStop(CamelContext context)
LifecycleStrategyCamelContext.onContextStop in interface LifecycleStrategycontext - the camel contextpublic void onComponentAdd(String name, Component component)
LifecycleStrategyComponent.onComponentAdd in interface LifecycleStrategyname - the unique name of this componentcomponent - the added componentpublic void onComponentRemove(String name, Component component)
LifecycleStrategyComponent.onComponentRemove in interface LifecycleStrategyname - the unique name of this componentcomponent - the removed componentpublic void onEndpointAdd(Endpoint endpoint)
ManagedEndpoint and
register that with the mbean server.onEndpointAdd in interface LifecycleStrategyendpoint - the Endpoint attempted to be addedpublic void onEndpointRemove(Endpoint endpoint)
LifecycleStrategyEndpoint.onEndpointRemove in interface LifecycleStrategyendpoint - the removed endpointpublic void onServiceAdd(CamelContext context, Service service, Route route)
LifecycleStrategyService.onServiceAdd in interface LifecycleStrategycontext - the camel contextservice - the added serviceroute - the route the service belongs to if any possible to determinepublic void onServiceRemove(CamelContext context, Service service, Route route)
LifecycleStrategyService.onServiceRemove in interface LifecycleStrategycontext - the camel contextservice - the removed serviceroute - the route the service belongs to if any possible to determinepublic void onRoutesAdd(Collection<Route> routes)
LifecycleStrategyRoute(s).onRoutesAdd in interface LifecycleStrategyroutes - the added routespublic void onRoutesRemove(Collection<Route> routes)
LifecycleStrategyRoute(s).onRoutesRemove in interface LifecycleStrategyroutes - the removed routespublic void onErrorHandlerAdd(RouteContext routeContext, Processor errorHandler, ErrorHandlerFactory errorHandlerBuilder)
LifecycleStrategyonErrorHandlerAdd in interface LifecycleStrategyrouteContext - the added route contexterrorHandler - the error handlererrorHandlerBuilder - the error handler builderpublic void onErrorHandlerRemove(RouteContext routeContext, Processor errorHandler, ErrorHandlerFactory errorHandlerBuilder)
LifecycleStrategyonErrorHandlerRemove in interface LifecycleStrategyrouteContext - the removed route contexterrorHandler - the error handlererrorHandlerBuilder - the error handler builderpublic void onThreadPoolAdd(CamelContext camelContext, ThreadPoolExecutor threadPool, String id, String sourceId, String routeId, String threadPoolProfileId)
LifecycleStrategyonThreadPoolAdd in interface LifecycleStrategycamelContext - the camel contextthreadPool - the thread poolid - id of the thread pool (can be null in special cases)sourceId - id of the source creating the thread pool (can be null in special cases)routeId - id of the route for the source (is null if no source)threadPoolProfileId - id of the thread pool profile, if used for creating this thread pool (can be null)public void onThreadPoolRemove(CamelContext camelContext, ThreadPoolExecutor threadPool)
LifecycleStrategyonThreadPoolRemove in interface LifecycleStrategycamelContext - the camel contextthreadPool - the thread poolpublic void onRouteContextCreate(RouteContext routeContext)
LifecycleStrategyRouteContext(s).onRouteContextCreate in interface LifecycleStrategyrouteContext - the added route contextprotected boolean registerProcessor(ProcessorDefinition<?> processor)
protected void manageObject(Object me) throws Exception
me - the managed objectException - is thrown if error registering the object for managementprotected void unmanageObject(Object me) throws Exception
me - the managed objectException - is thrown if error unregistering the managed objectprotected boolean shouldRegister(Object service, Route route)
ManagementAgent has options which controls when to register.
This allows us to only register mbeans accordingly. For example by default any
dynamic endpoints is not registered. This avoids to register excessive mbeans, which
most often is not desired.service - the object to registerroute - an optional route the mbean is associated with, can be nullprotected void doStart()
throws Exception
ServiceSupportServiceSupport.doStop() for more details.doStart in class ServiceSupportExceptionServiceSupport.doStop()protected void doStop()
throws Exception
ServiceSupportServiceSupport.doStop() method when
the service is being stopped. This method will also be invoked
if the service is still in uninitialized state (eg has not
been started). The method is always called to allow the service
to do custom logic when the service is being stopped, such as when
CamelContext is shutting down.doStop in class ServiceSupportExceptionServiceSupport.doStart()Apache Camel