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

INT-8 polishing

Browse Source
This commit is contained in:
Mark Fisher
2010-05-05 13:19:23 +00:00
parent 960997694b
commit 7522726ab9
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
org.springframework.integration/src/main/java/org/springframework/integration/transformer/ClaimCheckOutTransformer.java
View File

@@ -24,8 +24,9 @@ import org.springframework.integration.store.MessageStore;
import org.springframework.util.Assert;
/**
* Transformer that accepts a Message whose payload is a UUID and retrieves the
* Message associated with that id from a MessageStore if available (else null).
* Transformer that accepts a Message whose payload is a UUID and retrieves the Message associated
* with that id from a MessageStore if available. An Exception will be thrown if no Message with
* that ID can be retrieved from the given MessageStore.
*
* @author Mark Fisher
* @since 2.0
@@ -50,7 +51,8 @@ public class ClaimCheckOutTransformer extends AbstractTransformer {
Assert.isTrue(message.getPayload() instanceof UUID, "payload must be a UUID");
UUID id = (UUID) message.getPayload();
Message<?> retrievedMessage = this.messageStore.getMessage(id);
Assert.notNull(retrievedMessage, "unable to locate Message for ID: " + id);
Assert.notNull(retrievedMessage, "unable to locate Message for ID: " + id
+ " within MessageStore [" + this.messageStore + "]");
MessageBuilder<?> responseBuilder = MessageBuilder.fromMessage(retrievedMessage);
// headers on the 'current' message take precedence
responseBuilder.copyHeaders(message.getHeaders());