diff --git a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ClientRSocketConnector.java b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ClientRSocketConnector.java
index c8b014f3b9..920360e94b 100644
--- a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ClientRSocketConnector.java
+++ b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ClientRSocketConnector.java
@@ -38,7 +38,7 @@ import reactor.core.publisher.Mono;
  * <p>
  * Note: the {@link RSocketFactory.ClientRSocketFactory#acceptor(java.util.function.Function)}
  * in the provided {@link #factoryConfigurer} is overridden with an internal
- * {@link IntegrationRSocketMessageHandler#clientAcceptor()}
+ * {@link IntegrationRSocketMessageHandler#clientResponder()}
  * for the proper Spring Integration channel adapter mappings.
  *
  * @author Artem Bilan
@@ -126,7 +126,7 @@ public class ClientRSocketConnector extends AbstractRSocketConnector {
 						.dataMimeType(getDataMimeType().toString())
 						.metadataMimeType(getMetadataMimeType().toString());
 		this.factoryConfigurer.accept(clientFactory);
-		clientFactory.acceptor(this.rSocketMessageHandler.clientAcceptor());
+		clientFactory.acceptor(this.rSocketMessageHandler.clientResponder());
 		Payload connectPayload = EmptyPayload.INSTANCE;
 		if (this.connectRoute != null) {
 			connectPayload = DefaultPayload.create(this.connectData, this.connectRoute);
diff --git a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ServerRSocketConnector.java b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ServerRSocketConnector.java
index abd070fa48..6f1e56cb3a 100644
--- a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ServerRSocketConnector.java
+++ b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ServerRSocketConnector.java
@@ -52,7 +52,7 @@ import reactor.netty.http.server.HttpServer;
  * <p>
  * Note: the {@link RSocketFactory.ServerRSocketFactory#acceptor(io.rsocket.SocketAcceptor)}
  * in the provided {@link #factoryConfigurer} is overridden with an internal
- * {@link ServerRSocketMessageHandler#serverAcceptor()}
+ * {@link ServerRSocketMessageHandler#serverResponder()}
  * for the proper Spring Integration channel adapter mappings.
  *
  * @author Artem Bilan
@@ -131,7 +131,7 @@ public class ServerRSocketConnector extends AbstractRSocketConnector
 
 		this.serverMono =
 				serverFactory
-						.acceptor(serverRSocketMessageHandler().serverAcceptor())
+						.acceptor(serverRSocketMessageHandler().serverResponder())
 						.transport(this.serverTransport)
 						.start()
 						.cache();
diff --git a/spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGatewayIntegrationTests.java b/spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGatewayIntegrationTests.java
index e2d762e47a..3d52642c1a 100644
--- a/spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGatewayIntegrationTests.java
+++ b/spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGatewayIntegrationTests.java
@@ -119,7 +119,7 @@ public class RSocketOutboundGatewayIntegrationTests {
 		serverContext = new AnnotationConfigApplicationContext(ServerConfig.class);
 		server = RSocketFactory.receive()
 				.frameDecoder(PayloadDecoder.ZERO_COPY)
-				.acceptor(serverContext.getBean(RSocketMessageHandler.class).serverAcceptor())
+				.acceptor(serverContext.getBean(RSocketMessageHandler.class).serverResponder())
 				.transport(TcpServerTransport.create("localhost", 0))
 				.start()
 				.block();
@@ -531,7 +531,7 @@ public class RSocketOutboundGatewayIntegrationTests {
 					.dataMimeType("text/plain")
 					.metadataMimeType("message/x.rsocket.routing.v0")
 					.frameDecoder(PayloadDecoder.ZERO_COPY)
-					.acceptor(messageHandler().clientAcceptor())
+					.acceptor(messageHandler().clientResponder())
 					.transport(TcpClientTransport.create("localhost", server.address().getPort()))
 					.start()
 					.block();