diff --git a/spring-integration-core/src/main/java/org/springframework/integration/gateway/MessagingGatewaySupport.java b/spring-integration-core/src/main/java/org/springframework/integration/gateway/MessagingGatewaySupport.java index 11bcb4898e..650ac26fcf 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/gateway/MessagingGatewaySupport.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/gateway/MessagingGatewaySupport.java @@ -899,7 +899,7 @@ public abstract class MessagingGatewaySupport extends AbstractEndpoint @Override public void subscribeTo(Publisher> publisher) { - publisher.subscribe(MonoProcessor.fromSink(replyMono)); + publisher.subscribe(MonoProcessor.fromSink(this.replyMono)); } }