org.springframework.integration.transformer
Class AbstractPayloadTransformer<T,U>
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.transformer.AbstractTransformer
org.springframework.integration.transformer.AbstractPayloadTransformer<T,U>
- All Implemented Interfaces:
- BeanFactoryAware, BeanNameAware, InitializingBean, NamedComponent, Transformer
- Direct Known Subclasses:
- JsonToObjectTransformer, MapToObjectTransformer, ObjectToJsonTransformer, ObjectToMapTransformer, ObjectToStringTransformer, PayloadTypeConvertingTransformer, SourceCreatingTransformer, UnmarshallingTransformer
public abstract class AbstractPayloadTransformer<T,U>
- extends AbstractTransformer
A base class for Transformer
implementations that modify the payload
of a Message
. If the return value is itself a Message, it will be
used as the result. Otherwise, the return value will be used as the payload
of the result Message.
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport |
afterPropertiesSet, getBeanFactory, getComponentName, getComponentType, getConversionService, getTaskScheduler, onInit, setBeanFactory, setBeanName, setComponentName, setConversionService, setTaskScheduler, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
AbstractPayloadTransformer
public AbstractPayloadTransformer()
doTransform
public final U doTransform(Message<?> message)
throws java.lang.Exception
- Description copied from class:
AbstractTransformer
- Subclasses must implement this method to provide the transformation
logic. If the return value is itself a Message, it will be used as the
result. Otherwise, any non-null return value will be used as the payload
of the result Message.
- Specified by:
doTransform
in class AbstractTransformer
- Throws:
java.lang.Exception
transformPayload
protected abstract U transformPayload(T payload)
throws java.lang.Exception
- Throws:
java.lang.Exception