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

Fix RSocketOutboundGateway to use RetrieveSpec

Browse Source 
Related to https://github.com/spring-projects/spring-framework/issues/24073
This commit is contained in:
Artem Bilan
2019-11-25 13:20:39 -05:00
parent 516ecbcf8b
commit d9df857dc1
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -248,7 +248,7 @@ public class RSocketOutboundGateway extends AbstractReplyProducingMessageHandler
return requestSpec;
}
private RSocketRequester.RequestSpec prepareRequestSpec(RSocketRequester.RequestSpec requestSpec,
private RSocketRequester.RetrieveSpec prepareRequestSpec(RSocketRequester.RequestSpec requestSpec,
Message<?> requestMessage) {
Object payload = requestMessage.getPayload();
@@ -262,7 +262,7 @@ public class RSocketOutboundGateway extends AbstractReplyProducingMessageHandler
}
}
private RSocketRequester.RequestSpec prepareRequestSpecForPublisher(RSocketRequester.RequestSpec requestSpec,
private RSocketRequester.RetrieveSpec prepareRequestSpecForPublisher(RSocketRequester.RequestSpec requestSpec,
Publisher<?> payload, Object publisherElementType) {
if (publisherElementType instanceof Class<?>) {
@@ -273,7 +273,7 @@ public class RSocketOutboundGateway extends AbstractReplyProducingMessageHandler
}
}
private Mono<?> performRequest(RSocketRequester.RequestSpec requestSpec, Message<?> requestMessage) {
private Mono<?> performRequest(RSocketRequester.RetrieveSpec requestSpec, Message<?> requestMessage) {
Command command = this.commandExpression.getValue(this.evaluationContext, requestMessage, Command.class);
Assert.notNull(command,
() -> "The 'command' [" + this.commandExpression + "] must not evaluate to null");