public class ApplicationEventPublishingMessageHandler extends AbstractMessageHandler implements ApplicationEventPublisherAware
MessageHandler that publishes each Message
it receives as a MessagingEvent. The MessagingEvent is a subclass of
Spring's ApplicationEvent used by this adapter to simply wrap the
Message.
If the publishPayload flag is specified to true, the payload
will be published as is without wrapping to any ApplicationEvent.
IntegrationManagement.ManagementOverridesEXPRESSION_PARSER, loggerMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEHIGHEST_PRECEDENCE, LOWEST_PRECEDENCE| Constructor and Description |
|---|
ApplicationEventPublishingMessageHandler() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
handleMessageInternal(Message<?> message) |
void |
setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) |
void |
setPublishPayload(boolean publishPayload)
Specify if
payload should be published as is
or the whole message must be wrapped to the MessagingEvent. |
handleMessage, onComplete, onError, onNext, onSubscribebuildSendTimer, configureMetrics, destroy, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getHandlerMetrics, getIntegrationPatternType, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMetricsCaptor, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onInit, registerMetricsCaptor, reset, sendTimer, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled, shouldTrackafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waiterrorCount, handleCountgetBeanName, getComponentNamepublic ApplicationEventPublishingMessageHandler()
public void setPublishPayload(boolean publishPayload)
payload should be published as is
or the whole message must be wrapped to the MessagingEvent.publishPayload - the boolean flag to wrap the message
to the MessagingEvent or publish payload
as is. Defaults to false.ApplicationEventPublisher.publishEvent(Object)public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher in interface ApplicationEventPublisherAwareprotected void handleMessageInternal(Message<?> message)
handleMessageInternal in class AbstractMessageHandler