Fix MessagingGatewaySupport implementors

The `AmqpInboundGateway` and `JmsInboundGateway` don't delegate to `super`
in their `doStart()/doStop()` implementations causing the problem with
an internal `replyMessageCorrelator` missed the proper lifecycle
management

**Cherry-pick to 5.1.x & 5.0.x**
This commit is contained in:
Artem Bilan
2019-05-08 13:35:11 -04:00
committed by Gary Russell
parent 34bcd7d60c
commit 756cd41085
2 changed files with 14 additions and 9 deletions

View File

@@ -39,6 +39,7 @@ public class JmsInboundGateway extends MessagingGatewaySupport implements Dispos
public JmsInboundGateway(AbstractMessageListenerContainer listenerContainer,
ChannelPublishingJmsMessageListener listener) {
this.endpoint = new JmsMessageDrivenEndpoint(listenerContainer, listener);
}
@@ -78,11 +79,13 @@ public class JmsInboundGateway extends MessagingGatewaySupport implements Dispos
@Override
protected void doStart() {
super.doStart();
this.endpoint.start();
}
@Override
protected void doStop() {
super.doStop();
this.endpoint.stop();
}