diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/transformer/AbstractPayloadTransformer.java b/org.springframework.integration/src/main/java/org/springframework/integration/transformer/AbstractPayloadTransformer.java index d85a42c40e..64fdd8fa62 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/transformer/AbstractPayloadTransformer.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/transformer/AbstractPayloadTransformer.java @@ -33,6 +33,9 @@ public abstract class AbstractPayloadTransformer implements Transformer { U result = this.transformPayload((T) message.getPayload()); return MessageBuilder.withPayload(result).copyHeaders(message.getHeaders()).build(); } + catch (MessageTransformationException e) { + throw e; + } catch (Exception e) { throw new MessageTransformationException(message, "failed to transform message payload", e); }