Rename {client|server}Acceptor to Responder

See gh-23170

Author: rstoyanchev

spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketRequesterBuilder.java

@@ -125,7 +125,7 @@ private Mono<RSocketRequester> doConnect(ClientTransport transport) {
 			messageHandler.setHandlers(this.handlers);
 			messageHandler.setRSocketStrategies(rsocketStrategies);
 			messageHandler.afterPropertiesSet();
-			rsocketFactory.acceptor(messageHandler.clientAcceptor());
+			rsocketFactory.acceptor(messageHandler.clientResponder());
 		}
 		rsocketFactory.frameDecoder(PayloadDecoder.ZERO_COPY);
 		this.factoryConfigurers.forEach(consumer -> consumer.accept(rsocketFactory));

spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/RSocketMessageHandler.java

@@ -53,7 +53,7 @@
  * Extension of {@link MessageMappingMessageHandler} to use as an RSocket
  * responder by handling incoming streams via {@code @MessageMapping} annotated
  * methods.
- * <p>Use {@link #clientAcceptor()} and {@link #serverAcceptor()} to obtain
+ * <p>Use {@link #clientResponder()} and {@link #serverResponder()} to obtain
  * {@link io.rsocket.RSocketFactory.ClientRSocketFactory#acceptor(Function) client} or
  * {@link io.rsocket.RSocketFactory.ServerRSocketFactory#acceptor(SocketAcceptor) server}
  * side adapters.
@@ -270,7 +270,7 @@ protected void handleNoMatch(@Nullable RouteMatcher.Route destination, Message<?
 	 * <p>Subsequent stream requests can be handled with
 	 * {@link MessageMapping MessageMapping} methods.
 	 */
-	public SocketAcceptor serverAcceptor() {
+	public SocketAcceptor serverResponder() {
 		return (setupPayload, sendingRSocket) -> {
 			MessagingRSocket responder = createResponder(setupPayload, sendingRSocket);
 			return responder.handleConnectionSetupPayload(setupPayload).then(Mono.just(responder));
@@ -291,7 +291,7 @@ public SocketAcceptor serverAcceptor() {
 	 * <p>Subsequent stream requests can be handled with
 	 * {@link MessageMapping MessageMapping} methods.
 	 */
-	public BiFunction<ConnectionSetupPayload, RSocket, RSocket> clientAcceptor() {
+	public BiFunction<ConnectionSetupPayload, RSocket, RSocket> clientResponder() {
 		return (setupPayload, sendingRSocket) -> {
 			MessagingRSocket responder = createResponder(setupPayload, sendingRSocket);
 			responder.handleConnectionSetupPayload(setupPayload).subscribe();

spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketBufferLeakTests.java

@@ -79,7 +79,7 @@ public static void setupOnce() {
 		server = RSocketFactory.receive()
 				.frameDecoder(PayloadDecoder.ZERO_COPY)
 				.addResponderPlugin(payloadInterceptor) // intercept responding
-				.acceptor(context.getBean(RSocketMessageHandler.class).serverAcceptor())
+				.acceptor(context.getBean(RSocketMessageHandler.class).serverResponder())
 				.transport(TcpServerTransport.create("localhost", 7000))
 				.start()
 				.block();

spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketClientToServerIntegrationTests.java

@@ -68,7 +68,7 @@ public static void setupOnce() {
 		server = RSocketFactory.receive()
 				.addResponderPlugin(interceptor)
 				.frameDecoder(PayloadDecoder.ZERO_COPY)
-				.acceptor(context.getBean(RSocketMessageHandler.class).serverAcceptor())
+				.acceptor(context.getBean(RSocketMessageHandler.class).serverResponder())
 				.transport(TcpServerTransport.create("localhost", 7000))
 				.start()
 				.block();

spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketServerToClientIntegrationTests.java

@@ -65,7 +65,7 @@ public static void setupOnce() {
 
 		server = RSocketFactory.receive()
 				.frameDecoder(PayloadDecoder.ZERO_COPY)
-				.acceptor(context.getBean(RSocketMessageHandler.class).serverAcceptor())
+				.acceptor(context.getBean(RSocketMessageHandler.class).serverResponder())
 				.transport(TcpServerTransport.create("localhost", 0))
 				.start()
 				.block();

spring-messaging/src/test/kotlin/org/springframework/messaging/rsocket/RSocketClientToServerCoroutinesIntegrationTests.kt

@@ -202,7 +202,7 @@ class RSocketClientToServerCoroutinesIntegrationTests {
 			server = RSocketFactory.receive()
 					.addResponderPlugin(interceptor)
 					.frameDecoder(PayloadDecoder.ZERO_COPY)
-					.acceptor(context.getBean(RSocketMessageHandler::class.java).serverAcceptor())
+					.acceptor(context.getBean(RSocketMessageHandler::class.java).serverResponder())
 					.transport(TcpServerTransport.create("localhost", 7000))
 					.start()
 					.block()!!