Fix RSocketOutboundGateway to use RetrieveSpec

Related to spring-projects/spring-framework#24073
spring-projects · Nov 25, 2019 · d9df857 · d9df857
1 parent 516ecbc
commit d9df857
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...rc/main/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGateway.java b/...rc/main/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGateway.java
@@ -248,7 +248,7 @@ private RSocketRequester.RequestSpec createRequestSpec(RSocketRequester rsocketR
 		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 @@ private RSocketRequester.RequestSpec prepareRequestSpec(RSocketRequester.Request
 		}
 	}
 
-	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 @@ private RSocketRequester.RequestSpec prepareRequestSpecForPublisher(RSocketReque
 		}
 	}
 
-	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");