diff --git a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/AbstractRSocketConnector.java b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/AbstractRSocketConnector.java index 35aa5dd705..9a3d99cf0e 100644 --- a/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/AbstractRSocketConnector.java +++ b/spring-integration-rsocket/src/main/java/org/springframework/integration/rsocket/AbstractRSocketConnector.java @@ -26,8 +26,8 @@ import org.springframework.context.SmartLifecycle; import org.springframework.core.codec.CharSequenceEncoder; import org.springframework.core.codec.StringDecoder; import org.springframework.core.io.buffer.DefaultDataBufferFactory; +import org.springframework.messaging.rsocket.MetadataExtractor; import org.springframework.messaging.rsocket.RSocketStrategies; -import org.springframework.messaging.rsocket.annotation.support.MetadataExtractor; import org.springframework.util.Assert; import org.springframework.util.MimeType; import org.springframework.util.MimeTypeUtils; @@ -126,7 +126,7 @@ public abstract class AbstractRSocketConnector * Configure a {@link MetadataExtractor} to extract the route and possibly * other metadata from the first payload of incoming requests. *

By default this is a - * {@link org.springframework.messaging.rsocket.annotation.support.DefaultMetadataExtractor} + * {@link org.springframework.messaging.rsocket.DefaultMetadataExtractor} * with the configured {@link RSocketStrategies} (and decoders), extracting a route * from {@code "message/x.rsocket.routing.v0"} or {@code "text/plain"} * metadata entries.