From 2ebbdde06dedcc9aef909648697648187db76a50 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Thu, 25 Apr 2019 14:10:16 -0400 Subject: [PATCH] GH-2901: Add missed delegates into JmsInGateway (#2903) Fixes https://github.com/spring-projects/spring-integration/issues/2901 **Cherry-pick to 5.1.x** --- .../integration/jms/JmsInboundGateway.java | 50 ++++++++++++++++++- 1 file changed, 49 insertions(+), 1 deletion(-) diff --git a/spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsInboundGateway.java b/spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsInboundGateway.java index 86d1a6c1f0..c2a510ffd1 100644 --- a/spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsInboundGateway.java +++ b/spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsInboundGateway.java @@ -45,7 +45,55 @@ public class JmsInboundGateway extends MessagingGatewaySupport implements Dispos @Override public void setRequestChannel(MessageChannel requestChannel) { super.setRequestChannel(requestChannel); - this.endpoint.getListener().setRequestChannel(requestChannel); + this.endpoint.setOutputChannel(requestChannel); + } + + @Override + public void setRequestChannelName(String requestChannelName) { + super.setRequestChannelName(requestChannelName); + this.endpoint.setOutputChannelName(requestChannelName); + } + + @Override + public void setReplyChannel(MessageChannel replyChannel) { + super.setReplyChannel(replyChannel); + this.endpoint.getListener().setReplyChannel(replyChannel); + } + + @Override + public void setReplyChannelName(String replyChannelName) { + super.setReplyChannelName(replyChannelName); + this.endpoint.getListener().setReplyChannelName(replyChannelName); + } + + @Override + public void setErrorChannel(MessageChannel errorChannel) { + super.setErrorChannel(errorChannel); + this.endpoint.setErrorChannel(errorChannel); + } + + @Override + public void setErrorChannelName(String errorChannelName) { + super.setErrorChannelName(errorChannelName); + this.endpoint.setErrorChannelName(errorChannelName); + } + + @Override + public void setRequestTimeout(long requestTimeout) { + super.setRequestTimeout(requestTimeout); + this.endpoint.setSendTimeout(requestTimeout); + } + + @Override + public void setReplyTimeout(long replyTimeout) { + super.setReplyTimeout(replyTimeout); + this.endpoint.getListener().setReplyTimeout(replyTimeout); + } + + @Override + public void setShouldTrack(boolean shouldTrack) { + super.setShouldTrack(shouldTrack); + this.endpoint.setShouldTrack(shouldTrack); } /**