INT-1886 fixed the refactoring mistake where send() was changed to sendAndReceive()

This commit is contained in:
Oleg Zhurakousky
2011-05-04 12:10:13 -04:00
parent d26159e1a6
commit b0cf5c0b47

View File

@@ -275,7 +275,7 @@ public class ChannelPublishingJmsMessageListener
MessageBuilder.fromMessage((Message<?>) result).copyHeaders(headers).build() :
MessageBuilder.withPayload(result).copyHeaders(headers).build();
if (!this.expectReply) {
this.gatewayDelegate.sendAndReceive(requestMessage);
this.gatewayDelegate.send(requestMessage);
}
else {
Message<?> replyMessage = this.gatewayDelegate.sendAndReceiveMessage(requestMessage);
@@ -412,8 +412,8 @@ public class ChannelPublishingJmsMessageListener
private class GatewayDelegate extends MessagingGatewaySupport {
public Object sendAndReceive(Object request) {
return super.sendAndReceive(request);
public void send(Object request) {
super.send(request);
}
public Message<?> sendAndReceiveMessage(Object request) {