public abstract class RoutePolicySupport extends ServiceSupport implements RoutePolicy
RoutePolicy implementations.| Modifier and Type | Field and Description |
|---|---|
protected org.slf4j.Logger |
log |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
RoutePolicySupport() |
| 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.
|
ExceptionHandler |
getExceptionHandler() |
protected void |
handleException(Throwable t)
Handles the given exception using the
getExceptionHandler() |
void |
onExchangeBegin(Route route,
Exchange exchange)
|
void |
onExchangeDone(Route route,
Exchange exchange)
|
void |
onInit(Route route)
Callback invoked when the
Route is being initialized |
void |
onRemove(Route route)
Callback invoked when the
Route is being removed from CamelContext |
void |
onResume(Route route)
Callback invoked when the
Route is being resumed |
void |
onStart(Route route)
Callback invoked when the
Route is being started |
void |
onStop(Route route)
Callback invoked when the
Route is being stopped |
void |
onSuspend(Route route)
Callback invoked when the
Route is being suspended |
void |
resumeRoute(Route route) |
void |
setExceptionHandler(ExceptionHandler exceptionHandler) |
boolean |
startConsumer(Consumer consumer) |
void |
startRoute(Route route) |
boolean |
stopConsumer(Consumer consumer) |
void |
stopRoute(Route route) |
void |
stopRoute(Route route,
long timeout,
TimeUnit timeUnit) |
void |
suspendRoute(Route route) |
void |
suspendRoute(Route route,
long timeout,
TimeUnit timeUnit) |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendprotected final org.slf4j.Logger log
public RoutePolicySupport()
public void onInit(Route route)
RoutePolicyRoute is being initializedonInit in interface RoutePolicyroute - the route being initializedpublic void onRemove(Route route)
RoutePolicyRoute is being removed from CamelContextonRemove in interface RoutePolicyroute - the route being removedpublic void onStart(Route route)
RoutePolicyRoute is being startedonStart in interface RoutePolicyroute - the route being startedpublic void onStop(Route route)
RoutePolicyRoute is being stoppedonStop in interface RoutePolicyroute - the route being stoppedpublic void onSuspend(Route route)
RoutePolicyRoute is being suspendedonSuspend in interface RoutePolicyroute - the route being suspendedpublic void onResume(Route route)
RoutePolicyRoute is being resumedonResume in interface RoutePolicyroute - the route being resumedpublic void onExchangeBegin(Route route, Exchange exchange)
RoutePolicyonExchangeBegin in interface RoutePolicyroute - the route where the exchange started fromexchange - the created exchangepublic void onExchangeDone(Route route, Exchange exchange)
RoutePolicyExchange is done being routed, where it started from the given Route
Notice this callback is invoked when the Exchange is done and the Route is the route where
the Exchange was started. Most often its also the route where the exchange is done. However its
possible to route an Exchange to other routes using endpoints such as
direct or seda. Bottom line is that the Route parameter may not be the endpoint
route and thus why we state its the starting route.onExchangeDone in interface RoutePolicyroute - the route where the exchange started fromexchange - the created exchangepublic boolean startConsumer(Consumer consumer) throws Exception
Exceptionpublic boolean stopConsumer(Consumer consumer) throws Exception
Exceptionpublic void startRoute(Route route) throws Exception
Exceptionpublic void resumeRoute(Route route) throws Exception
Exceptionpublic void suspendRoute(Route route) throws Exception
Exceptionpublic void suspendRoute(Route route, long timeout, TimeUnit timeUnit) throws Exception
Exceptionpublic void stopRoute(Route route, long timeout, TimeUnit timeUnit) throws Exception
Exceptionprotected void handleException(Throwable t)
getExceptionHandler()t - the exception to handleprotected 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()public ExceptionHandler getExceptionHandler()
public void setExceptionHandler(ExceptionHandler exceptionHandler)
Apache Camel