public class NotificationListeningMessageProducer extends MessageProducerSupport implements javax.management.NotificationListener
NotificationListener implementation that will send Messages
containing the JMX Notification instances as their payloads.| Constructor and Description |
|---|
NotificationListeningMessageProducer() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doStart()
Registers the notification listener with the specified ObjectNames.
|
protected void |
doStop()
Unregisters the notification listener.
|
java.lang.String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
void |
handleNotification(javax.management.Notification notification,
java.lang.Object handback)
Notification handling method implementation.
|
protected java.util.Collection<javax.management.ObjectName> |
retrieveMBeanNames() |
void |
setFilter(javax.management.NotificationFilter filter)
Specify a
NotificationFilter to be passed to the server
when registering this listener. |
void |
setHandback(java.lang.Object handback)
Specify a handback object to provide context to the listener
upon notification.
|
void |
setObjectName(javax.management.ObjectName... objectNames)
Specify the JMX ObjectNames (or patterns)
of the notification publisher
to which this notification listener should be subscribed.
|
void |
setServer(javax.management.MBeanServerConnection server)
Provide a reference to the MBeanServer where the notification
publishing MBeans are registered.
|
onInit, sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrackgetPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stopafterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetComponentNamepublic NotificationListeningMessageProducer()
public void setServer(javax.management.MBeanServerConnection server)
public void setObjectName(javax.management.ObjectName... objectNames)
public void setFilter(javax.management.NotificationFilter filter)
NotificationFilter to be passed to the server
when registering this listener. The filter may be null.public void setHandback(java.lang.Object handback)
public void handleNotification(javax.management.Notification notification,
java.lang.Object handback)
Notification as its payload, and if the handback object is
not null, it sets that as a Message header value. The Message is then
sent to this producer's output channel.handleNotification in interface javax.management.NotificationListenerpublic java.lang.String getComponentType()
IntegrationObjectSupportgetComponentType in interface NamedComponentgetComponentType in class IntegrationObjectSupportprotected void doStart()
doStart in class MessageProducerSupportprotected void doStop()
doStop in class MessageProducerSupportprotected java.util.Collection<javax.management.ObjectName> retrieveMBeanNames()