org.springframework.integration.handler

Class AbstractMessageProducingHandler

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.integration.handler.AbstractMessageProducingHandler

All Implemented Interfaces:

org.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.core.Ordered, ExpressionCapable, Orderable, MessageProducer, HeaderPropagationAware, NamedComponent, ConfigurableMetricsAware<AbstractMessageHandlerMetrics>, IntegrationManagement, IntegrationStatsManagement, MessageHandlerMetrics, TrackableComponent, org.springframework.messaging.MessageHandler, reactor.core.CoreSubscriber<org.springframework.messaging.Message<?>>

Direct Known Subclasses:

AbstractCorrelatingMessageHandler, AbstractReplyProducingMessageHandler, MessageHandlerChain, MockMessageHandler

public abstract class AbstractMessageProducingHandler
extends AbstractMessageHandler
implements MessageProducer, HeaderPropagationAware

The base AbstractMessageHandler implementation for the MessageProducer.

Author:

David Liu, Artem Bilan, Gary Russell, Marius Bogoevici since 4.1

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

Fields

Modifier and Type	Field and Description
protected MessagingTemplate	messagingTemplate

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
AbstractMessageProducingHandler()

Method Summary

Modifier and Type	Method and Description
void	addNotPropagatedHeaders(java.lang.String... headers) Add headers that will NOT be copied from the inbound message if shouldCopyRequestHeaders() is true, instead of overwriting the existing set.
protected org.springframework.messaging.Message<?>	createOutputMessage(java.lang.Object output, org.springframework.messaging.MessageHeaders requestHeaders)
java.util.Collection<java.lang.String>	getNotPropagatedHeaders() Get the header names this handler doesn't propagate.
org.springframework.messaging.MessageChannel	getOutputChannel() Return the the output channel.
protected boolean	isAsync()
protected void	onInit() Subclasses may implement this for initialization logic.
protected void	produceOutput(java.lang.Object reply, org.springframework.messaging.Message<?> requestMessage)
protected java.lang.Object	resolveErrorChannel(org.springframework.messaging.MessageHeaders requestHeaders)
protected void	sendErrorMessage(org.springframework.messaging.Message<?> requestMessage, java.lang.Throwable ex)
protected void	sendOutput(java.lang.Object output, java.lang.Object replyChannel, boolean useArgChannel) Send an output Message.
protected void	sendOutputs(java.lang.Object result, org.springframework.messaging.Message<?> requestMessage)
void	setAsync(boolean async) Allow async replies.
void	setNotPropagatedHeaders(java.lang.String... headers) Set headers that will NOT be copied from the inbound message if shouldCopyRequestHeaaders is true.
void	setOutputChannel(org.springframework.messaging.MessageChannel outputChannel) Specify the MessageChannel to which produced Messages should be sent.
void	setOutputChannelName(java.lang.String outputChannelName)
void	setSendTimeout(long sendTimeout) Set the timeout for sending reply Messages.
protected boolean	shouldCopyRequestHeaders() Subclasses may override this.
protected boolean	shouldSplitOutput(java.lang.Iterable<?> reply)

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

configureMetrics, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, handleMessageInternal, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getComponentName

Methods inherited from interface reactor.core.CoreSubscriber

currentContext

Field Detail

messagingTemplate

protected final MessagingTemplate messagingTemplate

Constructor Detail

AbstractMessageProducingHandler

public AbstractMessageProducingHandler()

Method Detail

setSendTimeout

public void setSendTimeout(long sendTimeout)

Set the timeout for sending reply Messages.

Parameters:

sendTimeout - The send timeout.

setOutputChannel

public void setOutputChannel(org.springframework.messaging.MessageChannel outputChannel)

Description copied from interface: MessageProducer

Specify the MessageChannel to which produced Messages should be sent.

Specified by:

setOutputChannel in interface MessageProducer

Parameters:

outputChannel - The output channel.

setOutputChannelName

public void setOutputChannelName(java.lang.String outputChannelName)

setAsync

public final void setAsync(boolean async)

Allow async replies. If the handler reply is a ListenableFuture, send the output when it is satisfied rather than sending the future as the result. Ignored for return types other than ListenableFuture.

Parameters:

async - true to allow.

Since:

4.3

isAsync

protected boolean isAsync()

Returns:

true if this handler supports async replies.

Since:

4.3

See Also:

setAsync(boolean)

setNotPropagatedHeaders

public void setNotPropagatedHeaders(java.lang.String... headers)

Set headers that will NOT be copied from the inbound message if shouldCopyRequestHeaaders is true.

Specified by:

setNotPropagatedHeaders in interface HeaderPropagationAware

Parameters:

headers - the headers to not propagate from the inbound message.

Since:

4.3.10

getNotPropagatedHeaders

public java.util.Collection<java.lang.String> getNotPropagatedHeaders()

Get the header names this handler doesn't propagate.

Specified by:

getNotPropagatedHeaders in interface HeaderPropagationAware

Returns:

an immutable Collection of headers that will not be copied from the inbound message if shouldCopyRequestHeaders() is true.

Since:

4.3.10

See Also:

setNotPropagatedHeaders(String...)

addNotPropagatedHeaders

public void addNotPropagatedHeaders(java.lang.String... headers)

Add headers that will NOT be copied from the inbound message if shouldCopyRequestHeaders() is true, instead of overwriting the existing set.

Specified by:

addNotPropagatedHeaders in interface HeaderPropagationAware

Parameters:

headers - the headers to not propagate from the inbound message.

Since:

4.3.10

See Also:

setNotPropagatedHeaders(String...)

onInit

protected void onInit()
               throws java.lang.Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class AbstractMessageHandler

Throws:

java.lang.Exception - Any exception.

getOutputChannel

public org.springframework.messaging.MessageChannel getOutputChannel()

Description copied from interface: MessageProducer

Return the the output channel.

Specified by:

getOutputChannel in interface MessageProducer

Returns:

the channel.

sendOutputs

protected void sendOutputs(java.lang.Object result,
                           org.springframework.messaging.Message<?> requestMessage)

shouldSplitOutput

protected boolean shouldSplitOutput(java.lang.Iterable<?> reply)

produceOutput

protected void produceOutput(java.lang.Object reply,
                             org.springframework.messaging.Message<?> requestMessage)

createOutputMessage

protected org.springframework.messaging.Message<?> createOutputMessage(java.lang.Object output,
                                                                       org.springframework.messaging.MessageHeaders requestHeaders)

sendOutput

protected void sendOutput(java.lang.Object output,
                          java.lang.Object replyChannel,
                          boolean useArgChannel)

Send an output Message. The 'replyChannel' will be considered only if this handler's 'outputChannel' is null. In that case, the 'replyChannel' value must not also be null, and it must be an instance of either String or MessageChannel.

Parameters:

output - the output object to send

replyChannel - the 'replyChannel' value from the original request

useArgChannel - - use the replyChannel argument (must not be null), not the configured output channel.

shouldCopyRequestHeaders

protected boolean shouldCopyRequestHeaders()

Subclasses may override this. True by default.

Returns:

true if the request headers should be copied.

sendErrorMessage

protected void sendErrorMessage(org.springframework.messaging.Message<?> requestMessage,
                                java.lang.Throwable ex)

resolveErrorChannel

protected java.lang.Object resolveErrorChannel(org.springframework.messaging.MessageHeaders requestHeaders)