From d9df857dc13810431a21a9685a930f825d2aedec Mon Sep 17 00:00:00 2001
From: Artem Bilan <abilan@pivotal.io>
Date: Mon, 25 Nov 2019 13:20:39 -0500
Subject: [PATCH] Fix RSocketOutboundGateway to use RetrieveSpec

Related to https://github.com/spring-projects/spring-framework/issues/24073
---
 .../rsocket/outbound/RSocketOutboundGateway.java            | 6 +++---
 1 file changed, 3 insertions(+), 3 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 e9c4750b816..c7ba37dd936 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
@@ -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");