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

RSocketOG: rename method to prepareRetrieveSpec

Browse Source
This commit is contained in:
Artem Bilan
2019-11-25 14:04:42 -05:00
parent d9df857dc1
commit 75c9db1b0e
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGateway.java
View File

@@ -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();