From 7d68a65dc07e960e6d373f5a258d3e8b80f87819 Mon Sep 17 00:00:00 2001 From: Rossen Stoyanchev Date: Thu, 20 Jun 2019 11:21:12 +0100 Subject: [PATCH] Replace deprecated methods in RSocket tests --- .../messaging/rsocket/RSocketBufferLeakTests.java | 4 ++-- .../rsocket/RSocketClientToServerIntegrationTests.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) 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))