diff --git a/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketBufferLeakTests.java b/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketBufferLeakTests.java
index 231f4a2f44..18f8290f61 100644
--- a/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketBufferLeakTests.java
+++ b/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketBufferLeakTests.java
@@ -86,7 +86,7 @@ public class RSocketBufferLeakTests {
 
 		server = RSocketFactory.receive()
 				.frameDecoder(PayloadDecoder.ZERO_COPY)
-				.addServerPlugin(payloadInterceptor) // intercept responding
+				.addResponderPlugin(payloadInterceptor) // intercept responding
 				.acceptor(context.getBean(RSocketMessageHandler.class).serverAcceptor())
 				.transport(TcpServerTransport.create("localhost", 7000))
 				.start()
@@ -95,7 +95,7 @@ public class RSocketBufferLeakTests {
 		requester = RSocketRequester.builder()
 				.rsocketFactory(factory -> {
 					factory.frameDecoder(PayloadDecoder.ZERO_COPY);
-					factory.addClientPlugin(payloadInterceptor); // intercept outgoing requests
+					factory.addRequesterPlugin(payloadInterceptor); // intercept outgoing requests
 				})
 				.rsocketStrategies(context.getBean(RSocketStrategies.class))
 				.connectTcp("localhost", 7000)
diff --git a/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketClientToServerIntegrationTests.java b/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketClientToServerIntegrationTests.java
index 219d3da2f3..3741492491 100644
--- a/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketClientToServerIntegrationTests.java
+++ b/spring-messaging/src/test/java/org/springframework/messaging/rsocket/RSocketClientToServerIntegrationTests.java
@@ -65,7 +65,7 @@ public class RSocketClientToServerIntegrationTests {
 		context = new AnnotationConfigApplicationContext(ServerConfig.class);
 
 		server = RSocketFactory.receive()
-				.addServerPlugin(interceptor)
+				.addResponderPlugin(interceptor)
 				.frameDecoder(PayloadDecoder.ZERO_COPY)
 				.acceptor(context.getBean(RSocketMessageHandler.class).serverAcceptor())
 				.transport(TcpServerTransport.create("localhost", 7000))