Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Revert "RSocket - temporary work around for tests"

Browse Source 
This reverts commit 016bb32aa7.
This commit is contained in:
Gary Russell
2019-07-25 09:47:02 -04:00
parent 016bb32aa7
commit b660920da8
2 changed files with 0 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/IntegrationRSocketMessageHandler.java
View File

@@ -68,8 +68,6 @@ 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,

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

@@ -24,7 +24,6 @@ import java.util.Collections;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInfo;
@@ -83,7 +82,6 @@ import reactor.test.StepVerifier;
*/
@SpringJUnitConfig(RSocketOutboundGatewayIntegrationTests.ClientConfig.class)
@DirtiesContext
@Disabled // TODO temporary until routeMatcher initialization is moved to aPS()
public class RSocketOutboundGatewayIntegrationTests {
private static final String ROUTE_HEADER = "rsocket_route";