From 75c9db1b0e900b84120109e946e50466bd1af19d Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Mon, 25 Nov 2019 14:04:42 -0500 Subject: [PATCH] RSocketOG: rename method to prepareRetrieveSpec --- .../integration/rsocket/outbound/RSocketOutboundGateway.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGateway.java b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGateway.java index c7ba37dd93..061d5867d8 100644 --- a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGateway.java +++ b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGateway.java @@ -225,7 +225,7 @@ public class RSocketOutboundGateway extends AbstractReplyProducingMessageHandler return requesterMono .map((rSocketRequester) -> createRequestSpec(rSocketRequester, requestMessage)) - .map((requestSpec) -> prepareRequestSpec(requestSpec, requestMessage)) + .map((requestSpec) -> prepareRetrieveSpec(requestSpec, requestMessage)) .flatMap((responseSpec) -> performRequest(responseSpec, requestMessage)); } @@ -248,7 +248,7 @@ public class RSocketOutboundGateway extends AbstractReplyProducingMessageHandler return requestSpec; } - private RSocketRequester.RetrieveSpec prepareRequestSpec(RSocketRequester.RequestSpec requestSpec, + private RSocketRequester.RetrieveSpec prepareRetrieveSpec(RSocketRequester.RequestSpec requestSpec, Message requestMessage) { Object payload = requestMessage.getPayload();