RSocket - temporary work around for tests

2019-07-24 11:45:19 -04:00
parent 38b64543fb
commit 016bb32aa7
2 changed files with 4 additions and 0 deletions
--- 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
@@ -68,6 +68,8 @@ class IntegrationRSocketMessageHandler extends RSocketMessageHandler {
 	}

 	public void addEndpoint(IntegrationRSocketEndpoint endpoint) {
+		// TODO temporary until routeMatcher initialization is moved to aPS()
+		setRouteMatcher(getRSocketStrategies().routeMatcher());
 		registerHandlerMethod(endpoint, HANDLE_MESSAGE_METHOD,
 				new CompositeMessageCondition(
 						RSocketFrameTypeMessageCondition.REQUEST_CONDITION,