org.gytheio.health.camel

Class ComponentUnavailableActionStopCamelContext

java.lang.Object

org.gytheio.health.camel.ComponentUnavailableActionStopCamelContext

All Implemented Interfaces:

org.gytheio.health.ComponentUnavailableAction

public class ComponentUnavailableActionStopCamelContext
extends Object
implements org.gytheio.health.ComponentUnavailableAction

ComponentUnavailableAction which stops a given Camel context.

Author:

Ray Gauss II

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ComponentUnavailableActionStopCamelContext.StopContextRunnable Runnable which stops the Camel context.

Constructor Summary

Constructors

Constructor and Description
ComponentUnavailableActionStopCamelContext()

Method Summary

Methods

Modifier and Type	Method and Description
void	execute(Throwable e)
void	setCamelContext(org.apache.camel.CamelContext camelContext) Sets the Camel context to be stopped
void	setShutdownGracePeriodSeconds(long shutdownGracePeriodSeconds) Sets the time to allow Camel to gracefully wrap up shutdown before forcing.
void	setSpawnNewThread(boolean spawnNewThread) Sets whether or not to execute the shutdown in a new thread.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ComponentUnavailableActionStopCamelContext

public ComponentUnavailableActionStopCamelContext()

Method Detail

setShutdownGracePeriodSeconds

public void setShutdownGracePeriodSeconds(long shutdownGracePeriodSeconds)

Sets the time to allow Camel to gracefully wrap up shutdown before forcing.

Parameters:

shutdownGracePeriodSeconds -

setCamelContext

public void setCamelContext(org.apache.camel.CamelContext camelContext)

Sets the Camel context to be stopped

Parameters:

camelContext -

setSpawnNewThread

public void setSpawnNewThread(boolean spawnNewThread)

Sets whether or not to execute the shutdown in a new thread.

If we initiate the stop in another thread Camel / ActiveMQ's default behavior will rollback the transaction and put it in a DLQ.

If we initiate the stop in this thread Camel / ActiveMQ's default behavior will return the message to it's place in the queue.

Parameters:

spawnNewThread -

execute

public void execute(Throwable e)

Specified by:

execute in interface org.gytheio.health.ComponentUnavailableAction