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");