public class NotificationPublishingMessageHandler extends AbstractMessageHandler implements org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean
AbstractMessageHandler
implementation to publish an incoming message
as a JMX Notification
.
The OutboundMessageMapper
is used to convert a Message
to the Notification
.Modifier and Type | Class and Description |
---|---|
static class |
NotificationPublishingMessageHandler.PublisherDelegate
Simple class used for the actual MBean instances to be registered.
|
IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
Constructor and Description |
---|
NotificationPublishingMessageHandler(javax.management.ObjectName objectName) |
NotificationPublishingMessageHandler(java.lang.String objectName) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
protected void |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setDefaultNotificationType(java.lang.String defaultNotificationType)
Specify a dot-delimited String representing the Notification type to
use by default when no explicit Notification mapper
has been configured.
|
void |
setNotificationMapper(OutboundMessageMapper<javax.management.Notification> notificationMapper)
Set a mapper for creating Notifications from a Message.
|
configureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
afterPropertiesSet
getComponentName
public NotificationPublishingMessageHandler(javax.management.ObjectName objectName)
public NotificationPublishingMessageHandler(java.lang.String objectName)
public void setNotificationMapper(OutboundMessageMapper<javax.management.Notification> notificationMapper)
notificationMapper
- The notification mapper.public void setDefaultNotificationType(java.lang.String defaultNotificationType)
defaultNotificationType
- The default notification type.public java.lang.String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class AbstractMessageHandler
public final void onInit() throws java.lang.Exception
IntegrationObjectSupport
onInit
in class AbstractMessageHandler
java.lang.Exception
- Any exception.protected void handleMessageInternal(org.springframework.messaging.Message<?> message) throws java.lang.Exception
handleMessageInternal
in class AbstractMessageHandler
java.lang.Exception