diff --git a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/IntegrationRSocketMessageHandler.java b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/IntegrationRSocketMessageHandler.java index 797f1466c3..91f6b57244 100644 --- a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/IntegrationRSocketMessageHandler.java +++ b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/IntegrationRSocketMessageHandler.java @@ -71,7 +71,7 @@ class IntegrationRSocketMessageHandler extends RSocketMessageHandler { registerHandlerMethod(endpoint, HANDLE_MESSAGE_METHOD, new CompositeMessageCondition( RSocketFrameTypeMessageCondition.REQUEST_CONDITION, - new DestinationPatternsMessageCondition(endpoint.getPath(), getRouteMatcher()))); + new DestinationPatternsMessageCondition(endpoint.getPath(), getRouteMatcher()))); // NOSONAR } @Override diff --git a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ServerRSocketConnector.java b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ServerRSocketConnector.java index 6f1e56cb3a..ca049cad84 100644 --- a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ServerRSocketConnector.java +++ b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/ServerRSocketConnector.java @@ -189,9 +189,10 @@ public class ServerRSocketConnector extends AbstractRSocketConnector registerHandlerMethod(this, HANDLE_CONNECTION_SETUP_METHOD, new CompositeMessageCondition( RSocketFrameTypeMessageCondition.CONNECT_CONDITION, - new DestinationPatternsMessageCondition(new String[] { "*" }, getRouteMatcher()))); + new DestinationPatternsMessageCondition(new String[] { "*" }, getRouteMatcher()))); // NOSONAR } + @SuppressWarnings("unused") private void handleConnectionSetup(Message connectMessage) { DataBuffer dataBuffer = connectMessage.getPayload(); MessageHeaders messageHeaders = connectMessage.getHeaders();