org.springframework.integration.transformer

Class AbstractMessageProcessingTransformer

java.lang.Object

org.springframework.integration.transformer.AbstractMessageProcessingTransformer

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.context.Lifecycle, GenericTransformer<org.springframework.messaging.Message<?>,org.springframework.messaging.Message<?>>, Transformer

Direct Known Subclasses:

ExpressionEvaluatingTransformer, MethodInvokingTransformer

public abstract class AbstractMessageProcessingTransformer
extends java.lang.Object
implements Transformer, org.springframework.beans.factory.BeanFactoryAware, org.springframework.context.Lifecycle

Base class for Message Transformers that delegate to a MessageProcessor.

Author:

Mark Fisher, Artem Bilan

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractMessageProcessingTransformer(MessageProcessor<?> messageProcessor)

Method Summary

Modifier and Type	Method and Description
protected MessageBuilderFactory	getMessageBuilderFactory()
boolean	isRunning()
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
void	setNotPropagatedHeaders(java.lang.String... headers) Set headers that will NOT be copied from the inbound message if the handler is configured to copy headers.
void	start()
void	stop()
org.springframework.messaging.Message<?>	transform(org.springframework.messaging.Message<?> message)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractMessageProcessingTransformer

protected AbstractMessageProcessingTransformer(MessageProcessor<?> messageProcessor)

Method Detail

setBeanFactory

public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)

Specified by:

setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware

getMessageBuilderFactory

protected MessageBuilderFactory getMessageBuilderFactory()

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

setNotPropagatedHeaders

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

Set headers that will NOT be copied from the inbound message if the handler is configured to copy headers.

Parameters:

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

Since:

5.1

transform

public final org.springframework.messaging.Message<?> transform(org.springframework.messaging.Message<?> message)

Specified by:

transform in interface GenericTransformer<org.springframework.messaging.Message<?>,org.springframework.messaging.Message<?>>

Specified by:

transform in interface Transformer