public class JMXConsumer extends org.apache.camel.impl.DefaultConsumer implements NotificationListener
Constructor and Description |
---|
JMXConsumer(JMXEndpoint endpoint,
org.apache.camel.Processor processor) |
Modifier and Type | Method and Description |
---|---|
protected void |
addNotificationListener()
Adds a notification listener to the target bean.
|
protected void |
doStart()
Initializes the mbean server connection and starts listening for
Notification events from the object.
|
protected void |
doStop()
Removes the notification listeners and terminates the background connection polling process if it exists
|
protected org.apache.camel.component.jmx.JMXConsumer.ConnectionNotificationListener |
getConnectionNotificationListener()
Returns the connection notification listener; creates the default listener if one does not
already exist
|
protected NotificationXmlFormatter |
getFormatter() |
protected MBeanServerConnection |
getServerConnection() |
void |
handleNotification(Notification aNotification,
Object aHandback)
Processes the Notification received.
|
protected void |
removeNotificationListeners()
Removes the configured notification listener and the connection notification listener from the
connection
|
protected void |
scheduleDelayedStart()
Schedules execution of the doStart() operation to occur again after the reconnect delay
|
protected void |
scheduleReconnect()
Schedules an attempt to re-initialize a lost connection after the reconnect delay
|
protected void |
setServerConnection(MBeanServerConnection aServerConnection) |
createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public JMXConsumer(JMXEndpoint endpoint, org.apache.camel.Processor processor)
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultConsumer
Exception
protected org.apache.camel.component.jmx.JMXConsumer.ConnectionNotificationListener getConnectionNotificationListener()
protected void scheduleDelayedStart() throws Exception
Exception
protected void scheduleReconnect()
protected void addNotificationListener() throws Exception
Exception
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.DefaultConsumer
Exception
protected void removeNotificationListeners() throws Exception
Exception
protected MBeanServerConnection getServerConnection()
protected void setServerConnection(MBeanServerConnection aServerConnection)
public void handleNotification(Notification aNotification, Object aHandback)
NotificationXmlFormatter
handleNotification
in interface NotificationListener
NotificationListener.handleNotification(javax.management.Notification, java.lang.Object)
protected NotificationXmlFormatter getFormatter()
Apache Camel