org.springframework.integration.transformer
Class ContentEnricher

java.lang.Object
  org.springframework.integration.context.IntegrationObjectSupport
      org.springframework.integration.handler.AbstractMessageHandler
          org.springframework.integration.handler.AbstractReplyProducingMessageHandler
              org.springframework.integration.transformer.ContentEnricher

All Implemented Interfaces:

org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.core.Ordered, NamedComponent, Orderable, MessageHandler, MessageProducer, TrackableComponent

public class ContentEnricher
extends AbstractReplyProducingMessageHandler
implements org.springframework.context.Lifecycle

Content Enricher is a Message Transformer that can augment a message's payload with either static values or by optionally invoking a downstream message flow via its request channel and then applying values from the reply Message to the original payload.

Since:

2.1

Author:

Mark Fisher, Gunnar Hillert, Gary Russell

Field Summary

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

logger

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

ContentEnricher()

Method Summary

protected java.lang.Object	handleRequestMessage(Message<?> requestMessage) Subclasses must implement this method to handle the request Message.
boolean	isRunning() Lifecycle implementation.
void	onInit() Initializes the Content Enricher.
void	setPropertyExpressions(java.util.Map<java.lang.String,org.springframework.expression.Expression> propertyExpressions) Provide the map of expressions to evaluate when enriching the target payload.
void	setReplyChannel(MessageChannel replyChannel) Sets the content enricher's reply channel.
void	setReplyTimeout(java.lang.Long replyTimeout) Set the timeout value for receiving reply messages.
void	setRequestChannel(MessageChannel requestChannel) Sets the content enricher's request channel.
void	setRequestPayloadExpression(org.springframework.expression.Expression requestPayloadExpression) By default the original message's payload will be used as the actual payload that will be send to the request-channel.
void	setRequestTimeout(java.lang.Long requestTimeout) Set the timeout value for sending request messages.
void	setShouldClonePayload(boolean shouldClonePayload) Specify whether to clone payload objects to create the target object.
void	start() Lifecycle implementation.
void	stop() Lifecycle implementation.

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

getMessagingTemplate, handleMessageInternal, setChannelResolver, setOutputChannel, setRequiresReply, setSendTimeout, shouldCopyRequestHeaders

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

getComponentType, getOrder, handleMessage, setOrder, setShouldTrack

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

afterPropertiesSet, getBeanFactory, getComponentName, getConversionService, getTaskScheduler, setBeanFactory, setBeanName, setComponentName, setConversionService, 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.context.NamedComponent

getComponentName

Constructor Detail

ContentEnricher

public ContentEnricher()

Method Detail

setPropertyExpressions

public void setPropertyExpressions(java.util.Map<java.lang.String,org.springframework.expression.Expression> propertyExpressions)

Provide the map of expressions to evaluate when enriching the target payload. The keys should simply be property names, and the values should be Expressions that will evaluate against the reply Message as the root object.

setRequestChannel

public void setRequestChannel(MessageChannel requestChannel)

Sets the content enricher's request channel. If specified, then an internal Gateway will be initialized. Setting a request channel is optional. Not setting a request channel is useful in situations where message payloads shall be enriched with static values only.

setReplyChannel

public void setReplyChannel(MessageChannel replyChannel)

Sets the content enricher's reply channel. If not specified, yet the request channel is set, an anonymous reply channel will automatically created for each request.

setRequestTimeout

public void setRequestTimeout(java.lang.Long requestTimeout)

Set the timeout value for sending request messages. If not explicitly configured, the default is one second.

Parameters:

requestTimeout - the timeout value in milliseconds. Must not be null.

setReplyTimeout

public void setReplyTimeout(java.lang.Long replyTimeout)

Set the timeout value for receiving reply messages. If not explicitly configured, the default is one second.

Parameters:

replyTimeout - the timeout value in milliseconds. Must not be null.

setRequestPayloadExpression

public void setRequestPayloadExpression(org.springframework.expression.Expression requestPayloadExpression)

By default the original message's payload will be used as the actual payload that will be send to the request-channel. By providing a SpEL expression as value for this setter, a subset of the original payload, a header value or any other resolvable SpEL expression can be used as the basis for the payload, that will be send to the request-channel. For the Expression evaluation the full message is available as the root object. For instance the following SpEL expressions (among others) are possible:

• payload.foo
• headers.foobar
• new java.util.Date()
• 'foo' + 'bar'

If more sophisticated logic is required (e.g. changing the message headers etc.) please use additional downstream transformers.

setShouldClonePayload

public void setShouldClonePayload(boolean shouldClonePayload)

Specify whether to clone payload objects to create the target object. This is only applicable for payload types that implement Cloneable.

onInit

public void onInit()

Initializes the Content Enricher. Will instantiate an internal Gateway if the requestChannel is set.

Overrides:

onInit in class AbstractReplyProducingMessageHandler

handleRequestMessage

protected java.lang.Object handleRequestMessage(Message<?> requestMessage)

Description copied from class: AbstractReplyProducingMessageHandler

Subclasses must implement this method to handle the request Message. The return value may be a Message, a MessageBuilder, or any plain Object. The base class will handle the final creation of a reply Message from any of those starting points. If the return value is null, the Message flow will end here.

Specified by:

handleRequestMessage in class AbstractReplyProducingMessageHandler

start

public void start()

Lifecycle implementation. If no requestChannel is defined, this method has no effect as in that case no Gateway is initialized.

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Lifecycle implementation. If no requestChannel is defined, this method has no effect as in that case no Gateway is initialized.

Specified by:

stop in interface org.springframework.context.Lifecycle

isRunning

public boolean isRunning()

Lifecycle implementation. If no requestChannel is defined, this method will return always return true as no Gateway is initialized.

Specified by:

isRunning in interface org.springframework.context.Lifecycle