Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-903 AbstractPayloadTransformer now treats return values of type Message as the result rather than considering that the payload of a new Message.

Browse Source
This commit is contained in:
Mark Fisher
2009-12-07 11:41:35 +00:00
parent 55f5e1aaf3
commit 39c19c8c4a
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
org.springframework.integration/src/main/java/org/springframework/integration/transformer/AbstractPayloadTransformer.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2002-2008 the original author or authors.
* Copyright 2002-2009 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -21,17 +21,21 @@ import org.springframework.integration.message.MessageBuilder;
/**
* A base class for {@link Transformer} implementations that modify
* the payload of a {@link Message}.
* the payload of a {@link 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.
*
* @author Mark Fisher
*/
public abstract class AbstractPayloadTransformer<T, U> implements Transformer {
@SuppressWarnings("unchecked")
public final Message<?> transform(Message<?> message) {
try {
@SuppressWarnings("unchecked")
U result = this.transformPayload((T) message.getPayload());
return MessageBuilder.withPayload(result).copyHeaders(message.getHeaders()).build();
return (result instanceof Message)
? MessageBuilder.fromMessage((Message<?>) result).build()
: MessageBuilder.withPayload(result).copyHeaders(message.getHeaders()).build();
}
catch (MessageTransformationException e) {
throw e;