Skip to content

Commit e465a9b

Browse files
artembilangaryrussell
authored andcommitted
GH-2901: Add missed delegates into JmsInGateway (#2903)
Fixes #2901 **Cherry-pick to 5.1.x**
1 parent 66c45e5 commit e465a9b

File tree

1 file changed

+49
-1
lines changed

1 file changed

+49
-1
lines changed

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

Lines changed: 49 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,55 @@ public JmsInboundGateway(AbstractMessageListenerContainer listenerContainer,
4545
@Override
4646
public void setRequestChannel(MessageChannel requestChannel) {
4747
super.setRequestChannel(requestChannel);
48-
this.endpoint.getListener().setRequestChannel(requestChannel);
48+
this.endpoint.setOutputChannel(requestChannel);
49+
}
50+
51+
@Override
52+
public void setRequestChannelName(String requestChannelName) {
53+
super.setRequestChannelName(requestChannelName);
54+
this.endpoint.setOutputChannelName(requestChannelName);
55+
}
56+
57+
@Override
58+
public void setReplyChannel(MessageChannel replyChannel) {
59+
super.setReplyChannel(replyChannel);
60+
this.endpoint.getListener().setReplyChannel(replyChannel);
61+
}
62+
63+
@Override
64+
public void setReplyChannelName(String replyChannelName) {
65+
super.setReplyChannelName(replyChannelName);
66+
this.endpoint.getListener().setReplyChannelName(replyChannelName);
67+
}
68+
69+
@Override
70+
public void setErrorChannel(MessageChannel errorChannel) {
71+
super.setErrorChannel(errorChannel);
72+
this.endpoint.setErrorChannel(errorChannel);
73+
}
74+
75+
@Override
76+
public void setErrorChannelName(String errorChannelName) {
77+
super.setErrorChannelName(errorChannelName);
78+
this.endpoint.setErrorChannelName(errorChannelName);
79+
}
80+
81+
@Override
82+
public void setRequestTimeout(long requestTimeout) {
83+
super.setRequestTimeout(requestTimeout);
84+
this.endpoint.setSendTimeout(requestTimeout);
85+
}
86+
87+
@Override
88+
public void setReplyTimeout(long replyTimeout) {
89+
super.setReplyTimeout(replyTimeout);
90+
this.endpoint.getListener().setReplyTimeout(replyTimeout);
91+
}
92+
93+
@Override
94+
public void setShouldTrack(boolean shouldTrack) {
95+
super.setShouldTrack(shouldTrack);
96+
this.endpoint.setShouldTrack(shouldTrack);
4997
}
5098

5199
/**

0 commit comments

Comments
 (0)