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

GH-2901: Add missed delegates into JmsInGateway (#2903)

Browse Source 
Fixes https://github.com/spring-projects/spring-integration/issues/2901

**Cherry-pick to 5.1.x**
This commit is contained in:
Artem Bilan
2019-04-25 14:10:16 -04:00
committed by Gary Russell
parent 89e11f2c46
commit 2ebbdde06d
1 changed files with 49 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

50
spring-integration-jms/src/main/java/org/springframework/integration/jms/JmsInboundGateway.java
View File

@@ -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);
}
/**