diff --git a/org.springframework.integration.jms/src/main/java/org/springframework/integration/jms/ChannelPublishingJmsMessageListener.java b/org.springframework.integration.jms/src/main/java/org/springframework/integration/jms/ChannelPublishingJmsMessageListener.java index 914846de2e..e497f24939 100644 --- a/org.springframework.integration.jms/src/main/java/org/springframework/integration/jms/ChannelPublishingJmsMessageListener.java +++ b/org.springframework.integration.jms/src/main/java/org/springframework/integration/jms/ChannelPublishingJmsMessageListener.java @@ -157,7 +157,7 @@ public class ChannelPublishingJmsMessageListener implements SessionAwareMessageL jmsReply.setJMSCorrelationID(jmsMessage.getJMSMessageID()); } MessageProducer producer = session.createProducer(jmsMessage.getJMSReplyTo()); - producer.send(jmsMessage.getJMSReplyTo(), jmsReply); + producer.send(jmsReply); } } }