From b0cf5c0b4754ad55ee1ba480decf83f99ce0dc0e Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Wed, 4 May 2011 12:10:13 -0400 Subject: [PATCH] INT-1886 fixed the refactoring mistake where send() was changed to sendAndReceive() --- .../jms/ChannelPublishingJmsMessageListener.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-integration-jms/src/main/java/org/springframework/integration/jms/ChannelPublishingJmsMessageListener.java b/spring-integration-jms/src/main/java/org/springframework/integration/jms/ChannelPublishingJmsMessageListener.java index 8a080fd718..c77701a76f 100644 --- a/spring-integration-jms/src/main/java/org/springframework/integration/jms/ChannelPublishingJmsMessageListener.java +++ b/spring-integration-jms/src/main/java/org/springframework/integration/jms/ChannelPublishingJmsMessageListener.java @@ -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) {