Skip to content

Commit 9115644

Browse files
committed
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
1 parent c6a5ea8 commit 9115644

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

+2-1
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@
5252
import org.springframework.messaging.handler.annotation.MessageMapping;
5353
import org.springframework.messaging.rsocket.RSocketRequester;
5454
import org.springframework.messaging.rsocket.RSocketStrategies;
55+
import org.springframework.messaging.rsocket.annotation.ConnectMapping;
5556
import org.springframework.messaging.rsocket.annotation.support.RSocketMessageHandler;
5657
import org.springframework.messaging.rsocket.annotation.support.RSocketRequesterMethodArgumentResolver;
5758
import org.springframework.messaging.support.ErrorMessage;
@@ -627,7 +628,7 @@ Mono<Void> handleExceptionWithVoidReturnValue(IllegalStateException ex) {
627628
return Mono.delay(Duration.ofMillis(10)).then(Mono.empty());
628629
}
629630

630-
@MessageMapping("clientConnect")
631+
@ConnectMapping("clientConnect")
631632
void clientConnect(RSocketRequester requester) {
632633
this.clientRequester.onNext(requester);
633634
}

0 commit comments

Comments
 (0)