From b48ddef4c6a6234e9d1116c3f0eb2f5b0d156ef8 Mon Sep 17 00:00:00 2001 From: Rossen Stoyanchev Date: Tue, 9 Jun 2020 08:59:32 +0100 Subject: [PATCH] Upgrade to RSocket 1.0.1 --- build.gradle | 2 +- .../rsocket/DefaultRSocketRequesterBuilderTests.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/build.gradle b/build.gradle index add4ccf1a7..3f2bc0a863 100644 --- a/build.gradle +++ b/build.gradle @@ -29,7 +29,7 @@ configure(allprojects) { project -> mavenBom "com.fasterxml.jackson:jackson-bom:2.10.4" mavenBom "io.netty:netty-bom:4.1.50.Final" mavenBom "io.projectreactor:reactor-bom:Dysprosium-SR8" - mavenBom "io.rsocket:rsocket-bom:1.0.0" + mavenBom "io.rsocket:rsocket-bom:1.0.1" mavenBom "org.eclipse.jetty:jetty-bom:9.4.29.v20200521" mavenBom "org.jetbrains.kotlin:kotlin-bom:1.3.72" mavenBom "org.jetbrains.kotlinx:kotlinx-coroutines-bom:1.3.5" diff --git a/spring-messaging/src/test/java/org/springframework/messaging/rsocket/DefaultRSocketRequesterBuilderTests.java b/spring-messaging/src/test/java/org/springframework/messaging/rsocket/DefaultRSocketRequesterBuilderTests.java index f695228117..e47b526131 100644 --- a/spring-messaging/src/test/java/org/springframework/messaging/rsocket/DefaultRSocketRequesterBuilderTests.java +++ b/spring-messaging/src/test/java/org/springframework/messaging/rsocket/DefaultRSocketRequesterBuilderTests.java @@ -75,7 +75,7 @@ public class DefaultRSocketRequesterBuilderTests { @BeforeEach public void setup() { this.transport = mock(ClientTransport.class); - given(this.transport.connect(anyInt())).willReturn(Mono.just(this.connection)); + given(this.transport.connect()).willReturn(Mono.just(this.connection)); } @@ -106,7 +106,7 @@ public class DefaultRSocketRequesterBuilderTests { // RSocketStrategies and RSocketConnector configurers should have been called - verify(this.transport).connect(anyInt()); + verify(this.transport).connect(); verify(strategiesConfigurer).accept(any(RSocketStrategies.Builder.class)); verify(factoryConfigurer).configure(any(io.rsocket.RSocketFactory.ClientRSocketFactory.class)); assertThat(this.connectorConfigurer.connector()).isNotNull();