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

Disable Rsocket fire-n-forget for race condition

Browse Source
This commit is contained in:
abilan
2023-06-08 16:40:13 -04:00
parent 1093430b78
commit 30f1420d73
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -26,6 +26,7 @@ import io.rsocket.transport.netty.server.TcpServerTransport;
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;
import reactor.core.Disposable;
@@ -138,11 +139,13 @@ public class RSocketOutboundGatewayIntegrationTests {
}
}
@Disabled("Some race condition on subscriber dispose()")
@Test
void clientFireAndForget() {
fireAndForget(this.inputChannel, this.resultChannel, serverController, null);
}
@Disabled("Some race condition on subscriber dispose()")
@Test
void serverFireAndForget() {
fireAndForget(serverInputChannel, serverResultChannel, this.clientController, this.serverRsocketRequester);