From 710f7f858f1643bfe70a779ac2b163d062e2f28f Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Wed, 11 Mar 2009 20:36:07 +0000 Subject: [PATCH] INT-589 --- .../handler/AbstractReplyProducingMessageHandler.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/handler/AbstractReplyProducingMessageHandler.java b/org.springframework.integration/src/main/java/org/springframework/integration/handler/AbstractReplyProducingMessageHandler.java index a281e08a3c..232a04688a 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/handler/AbstractReplyProducingMessageHandler.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/handler/AbstractReplyProducingMessageHandler.java @@ -26,6 +26,7 @@ import org.springframework.integration.core.Message; import org.springframework.integration.core.MessageChannel; import org.springframework.integration.core.MessageHeaders; import org.springframework.integration.message.MessageBuilder; +import org.springframework.integration.message.MessageDeliveryException; import org.springframework.integration.message.MessageHandlingException; import org.springframework.util.Assert; @@ -102,7 +103,10 @@ public abstract class AbstractReplyProducingMessageHandler extends AbstractMessa MessageHeaders requestHeaders = message.getHeaders(); for (MessageBuilder builder : replyMessageHolder.builders()) { builder.copyHeadersIfAbsent(requestHeaders); - this.sendReplyMessage(builder.build(), replyChannel); + Message replyMessage = builder.build(); + if (!this.sendReplyMessage(replyMessage, replyChannel)) { + throw new MessageDeliveryException(replyMessage, "failed to send reply Message"); + } } }