From 91156444c4978105d2bdacb53c3f2931a2644fc3 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 9 Jul 2019 12:02:25 -0400 Subject: [PATCH] Fix RSocket tests according new `@ConnectMapping` For the `connect` frame Spring Messaging RSocket support has introduced an new `@ConnectMapping` annotation. * Use `@ConnectMapping` in the test controller's method to properly map to the connection from the client --- .../outbound/RSocketOutboundGatewayIntegrationTests.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 fa40819ab6..e2d762e47a 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 @@ -52,6 +52,7 @@ import org.springframework.messaging.handler.annotation.MessageExceptionHandler; import org.springframework.messaging.handler.annotation.MessageMapping; import org.springframework.messaging.rsocket.RSocketRequester; import org.springframework.messaging.rsocket.RSocketStrategies; +import org.springframework.messaging.rsocket.annotation.ConnectMapping; import org.springframework.messaging.rsocket.annotation.support.RSocketMessageHandler; import org.springframework.messaging.rsocket.annotation.support.RSocketRequesterMethodArgumentResolver; import org.springframework.messaging.support.ErrorMessage; @@ -627,7 +628,7 @@ public class RSocketOutboundGatewayIntegrationTests { return Mono.delay(Duration.ofMillis(10)).then(Mono.empty()); } - @MessageMapping("clientConnect") + @ConnectMapping("clientConnect") void clientConnect(RSocketRequester requester) { this.clientRequester.onNext(requester); }