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

INT-596

Browse Source
This commit is contained in:
Mark Fisher
2009-03-11 20:42:58 +00:00
parent 710f7f858f
commit 00bdb391e5
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
org.springframework.integration/src/main/java/org/springframework/integration/aggregator/AbstractMessageBarrierHandler.java
View File

@@ -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);