JAVA-27677: Reactivate core-java-os-2 and spring-6-rsocket (#15675)

This commit is contained in:
Bipin kumar 2024-02-07 16:14:13 +05:30 committed by GitHub
parent 7055bb3f6b
commit 322a38321c
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 7 additions and 1 deletions

View File

@ -60,6 +60,7 @@
<module>core-java-methods</module> <module>core-java-methods</module>
<module>core-java-networking-3</module> <module>core-java-networking-3</module>
<module>core-java-os</module> <module>core-java-os</module>
<module>core-java-os-2</module>
<module>core-java-perf-2</module> <module>core-java-perf-2</module>
<module>core-java-streams-4</module> <module>core-java-streams-4</module>
<module>core-java-streams-5</module> <module>core-java-streams-5</module>

View File

@ -817,6 +817,7 @@
<module>spring-5-webflux-2</module> <module>spring-5-webflux-2</module>
<module>spring-5-webflux</module> <module>spring-5-webflux</module>
<module>spring-5</module> <module>spring-5</module>
<module>spring-6-rsocket</module>
<module>spring-activiti</module> <module>spring-activiti</module>
<module>spring-actuator</module> <module>spring-actuator</module>
<module>spring-ai</module> <module>spring-ai</module>
@ -1056,6 +1057,7 @@
<module>spring-5-webflux-2</module> <module>spring-5-webflux-2</module>
<module>spring-5-webflux</module> <module>spring-5-webflux</module>
<module>spring-5</module> <module>spring-5</module>
<module>spring-6-rsocket</module>
<module>spring-activiti</module> <module>spring-activiti</module>
<module>spring-actuator</module> <module>spring-actuator</module>
<module>spring-ai</module> <module>spring-ai</module>

View File

@ -49,6 +49,8 @@
<properties> <properties>
<spring-boot.version>3.1.3</spring-boot.version> <spring-boot.version>3.1.3</spring-boot.version>
<org.slf4j.version>2.0.7</org.slf4j.version>
<logback.version>1.4.11</logback.version>
</properties> </properties>
</project> </project>

View File

@ -28,7 +28,8 @@ public class RSocketRequestResponseIntegrationTest {
@Test @Test
public void whenSendingStream_thenReceiveTheSameStream() { public void whenSendingStream_thenReceiveTheSameStream() {
String message = "test message"; String message = "test message";
assertEquals(message, client.sendMessage(Mono.just(message)) String response = "test message,Response!";
assertEquals(response, client.sendMessage(Mono.just(message))
.block()); .block());
} }