From 7522726ab9022efa2e1f00d5a0429a2fda43d386 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Wed, 5 May 2010 13:19:23 +0000 Subject: [PATCH] INT-8 polishing --- .../integration/transformer/ClaimCheckOutTransformer.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/transformer/ClaimCheckOutTransformer.java b/org.springframework.integration/src/main/java/org/springframework/integration/transformer/ClaimCheckOutTransformer.java index ebc44bb529..5adbe222dc 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/transformer/ClaimCheckOutTransformer.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/transformer/ClaimCheckOutTransformer.java @@ -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());