Fix RSocket module according latest SF

See spring-projects/spring-framework#23170

Author: artembilan

spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ClientRSocketConnector.java

@@ -38,7 +38,7 @@
  * <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 void afterPropertiesSet() {
 						.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);

spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ServerRSocketConnector.java

@@ -52,7 +52,7 @@
  * <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 void afterPropertiesSet() {
 
 		this.serverMono =
 				serverFactory
-						.acceptor(serverRSocketMessageHandler().serverAcceptor())
+						.acceptor(serverRSocketMessageHandler().serverResponder())
 						.transport(this.serverTransport)
 						.start()
 						.cache();

spring-integration-rsocket/src/test/java/org/springframework/integration/rsocket/outbound/RSocketOutboundGatewayIntegrationTests.java

@@ -119,7 +119,7 @@ static void setup() {
 		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 RSocket rsocketForServerRequests() {
 					.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();