Skip to content

Commit b660920

Browse files
committed
Revert "RSocket - temporary work around for tests"
This reverts commit 016bb32.
1 parent 016bb32 commit b660920

File tree

2 files changed

+0
-4
lines changed

2 files changed

+0
-4
lines changed

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

-2
Original file line numberDiff line numberDiff line change
@@ -68,8 +68,6 @@ public boolean detectEndpoints() {
6868
}
6969

7070
public void addEndpoint(IntegrationRSocketEndpoint endpoint) {
71-
// TODO temporary until routeMatcher initialization is moved to aPS()
72-
setRouteMatcher(getRSocketStrategies().routeMatcher());
7371
registerHandlerMethod(endpoint, HANDLE_MESSAGE_METHOD,
7472
new CompositeMessageCondition(
7573
RSocketFrameTypeMessageCondition.REQUEST_CONDITION,

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

-2
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@
2424
import org.junit.jupiter.api.AfterAll;
2525
import org.junit.jupiter.api.BeforeAll;
2626
import org.junit.jupiter.api.BeforeEach;
27-
import org.junit.jupiter.api.Disabled;
2827
import org.junit.jupiter.api.Test;
2928
import org.junit.jupiter.api.TestInfo;
3029

@@ -83,7 +82,6 @@
8382
*/
8483
@SpringJUnitConfig(RSocketOutboundGatewayIntegrationTests.ClientConfig.class)
8584
@DirtiesContext
86-
@Disabled // TODO temporary until routeMatcher initialization is moved to aPS()
8785
public class RSocketOutboundGatewayIntegrationTests {
8886

8987
private static final String ROUTE_HEADER = "rsocket_route";

0 commit comments

Comments
 (0)