public class NotificationPublishingMessageHandler extends AbstractMessageHandler implements BeanFactoryAware, InitializingBean
logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
Constructor and Description |
---|
NotificationPublishingMessageHandler(ObjectName objectName) |
NotificationPublishingMessageHandler(String objectName) |
Modifier and Type | Method and Description |
---|---|
String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
protected void |
handleMessageInternal(Message<?> message) |
void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setDefaultNotificationType(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<Notification> notificationMapper)
Set a mapper for creating Notifications from a Message.
|
getOrder, handleMessage, setOrder, setShouldTrack
afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
setBeanFactory
afterPropertiesSet
getComponentName
public NotificationPublishingMessageHandler(ObjectName objectName)
public NotificationPublishingMessageHandler(String objectName)
public void setNotificationMapper(OutboundMessageMapper<Notification> notificationMapper)
notificationMapper
- The notification mapper.public void setDefaultNotificationType(String defaultNotificationType)
defaultNotificationType
- The default notification type.public String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class AbstractMessageHandler
public final void onInit() throws Exception
IntegrationObjectSupport
onInit
in class IntegrationObjectSupport
Exception
- Any exception.protected void handleMessageInternal(Message<?> message) throws Exception
handleMessageInternal
in class AbstractMessageHandler
Exception