From 00bdb391e51837af1a1b6197d45481662cc9de27 Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Wed, 11 Mar 2009 20:42:58 +0000
Subject: [PATCH] INT-596

---
 .../aggregator/AbstractMessageBarrierHandler.java            | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/AbstractMessageBarrierHandler.java b/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/AbstractMessageBarrierHandler.java
index 9fa604f3fa..098ada7421 100644
--- a/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/AbstractMessageBarrierHandler.java
+++ b/org.springframework.integration/src/main/java/org/springframework/integration/aggregator/AbstractMessageBarrierHandler.java
@@ -38,6 +38,7 @@ import org.springframework.integration.core.MessageChannel;
 import org.springframework.integration.core.MessageHeaders;
 import org.springframework.integration.handler.AbstractMessageHandler;
 import org.springframework.integration.message.MessageBuilder;
+import org.springframework.integration.message.MessageDeliveryException;
 import org.springframework.integration.message.MessageHandler;
 import org.springframework.integration.message.MessageHandlingException;
 import org.springframework.integration.scheduling.IntervalTrigger;
@@ -296,7 +297,9 @@ public abstract class AbstractMessageBarrierHandler<T extends Collection<? exten
 						.setHeaderIfAbsent(MessageHeaders.REPLY_CHANNEL, defaultReplyChannel)
 						.build();
 			}
-			this.channelTemplate.send(message, replyChannel);
+			if (!this.channelTemplate.send(message, replyChannel)) {
+				throw new MessageDeliveryException(message, "failed to send reply Message");
+			}
 		}
 		else if (logger.isWarnEnabled()) {
 			logger.warn("unable to determine reply target for aggregation result: " + message);