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

SimpleMessagingGateway now supports a subscribable channel for its 'replyChannel'. However, when attempting to use the gateway for simple 'receive' operations, an exception will be thrown if the replyChannel is not a PollableChannel. The subscribable channel is only a relevant option when relying upon reply-message correlation.

Browse Source
This commit is contained in:
Mark Fisher
2008-09-19 13:19:13 +00:00
parent 045f96e2c0
commit bbc14e5bbe
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
org.springframework.integration/src/main/java/org/springframework/integration/gateway/SimpleMessagingGateway.java
View File

@@ -44,7 +44,7 @@ public class SimpleMessagingGateway extends MessagingGatewaySupport implements M
private volatile MessageChannel requestChannel;
private volatile PollableChannel replyChannel;
private volatile MessageChannel replyChannel;
private volatile MessageCreator messageCreator = new DefaultMessageCreator();
@@ -114,11 +114,11 @@ public class SimpleMessagingGateway extends MessagingGatewaySupport implements M
}
public Object receive() {
if (this.replyChannel == null) {
if (this.replyChannel == null || !(this.replyChannel instanceof PollableChannel)) {
throw new IllegalStateException(
"no-arg receive is not supported, because no reply channel has been configured");
"no-arg receive is not supported, because no pollable reply channel has been configured");
}
Message<?> message = this.getChannelTemplate().receive(this.replyChannel);
Message<?> message = this.getChannelTemplate().receive((PollableChannel) this.replyChannel);
return (message != null) ? this.messageMapper.mapMessage(message) : null;
}