diff --git a/build.gradle b/build.gradle index 0fef5edf6f..57ac2e422e 100644 --- a/build.gradle +++ b/build.gradle @@ -29,7 +29,7 @@ configure(allprojects) { project -> mavenBom "com.fasterxml.jackson:jackson-bom:2.10.3" mavenBom "io.netty:netty-bom:4.1.49.Final" mavenBom "io.projectreactor:reactor-bom:Dysprosium-SR7" - mavenBom "io.rsocket:rsocket-bom:1.0.0-RC7" + mavenBom "io.rsocket:rsocket-bom:1.0.0" mavenBom "org.eclipse.jetty:jetty-bom:9.4.28.v20200408" 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/main/java/org/springframework/messaging/rsocket/MetadataEncoder.java b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/MetadataEncoder.java index 7075e31226..dc7455627e 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/MetadataEncoder.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/MetadataEncoder.java @@ -25,8 +25,6 @@ import java.util.regex.Pattern; import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBufAllocator; import io.netty.buffer.CompositeByteBuf; -import io.rsocket.metadata.CompositeMetadataFlyweight; -import io.rsocket.metadata.TaggingMetadataFlyweight; import io.rsocket.metadata.WellKnownMimeType; import reactor.core.publisher.Mono; @@ -180,17 +178,18 @@ final class MetadataEncoder { Mono.fromCallable(() -> encodeEntries(this.metadataEntries)); } + @SuppressWarnings("deprecation") private DataBuffer encodeEntries(List entries) { if (this.isComposite) { CompositeByteBuf composite = this.allocator.compositeBuffer(); try { if (this.route != null) { - CompositeMetadataFlyweight.encodeAndAddMetadata(composite, this.allocator, + io.rsocket.metadata.CompositeMetadataFlyweight.encodeAndAddMetadata(composite, this.allocator, WellKnownMimeType.MESSAGE_RSOCKET_ROUTING, encodeRoute()); } entries.forEach(entry -> { Object value = entry.value(); - CompositeMetadataFlyweight.encodeAndAddMetadata( + io.rsocket.metadata.CompositeMetadataFlyweight.encodeAndAddMetadata( composite, this.allocator, entry.mimeType().toString(), value instanceof ByteBuf ? (ByteBuf) value : PayloadUtils.asByteBuf(encodeEntry(entry))); }); @@ -220,8 +219,9 @@ final class MetadataEncoder { } } + @SuppressWarnings("deprecation") private ByteBuf encodeRoute() { - return TaggingMetadataFlyweight.createRoutingMetadata( + return io.rsocket.metadata.TaggingMetadataFlyweight.createRoutingMetadata( this.allocator, Collections.singletonList(this.route)).getContent(); } diff --git a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/MessagingRSocket.java b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/MessagingRSocket.java index 8d80a42406..21c002bf98 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/MessagingRSocket.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/MessagingRSocket.java @@ -20,7 +20,6 @@ import java.util.Map; import java.util.concurrent.atomic.AtomicBoolean; import java.util.function.Function; -import io.rsocket.AbstractRSocket; import io.rsocket.ConnectionSetupPayload; import io.rsocket.Payload; import io.rsocket.RSocket; @@ -59,7 +58,7 @@ import org.springframework.util.RouteMatcher; * @author Rossen Stoyanchev * @since 5.2 */ -class MessagingRSocket extends AbstractRSocket { +class MessagingRSocket implements RSocket { private final MimeType dataMimeType;