diff --git a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketRequesterBuilder.java b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketRequesterBuilder.java index 0ff7b30240..5e49daa12a 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketRequesterBuilder.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/DefaultRSocketRequesterBuilder.java @@ -5,7 +5,7 @@ * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * - * http://www.apache.org/licenses/LICENSE-2.0 + * https://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, diff --git a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketRequester.java b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketRequester.java index b41f3910b3..911751f677 100644 --- a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketRequester.java +++ b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketRequester.java @@ -68,6 +68,21 @@ public interface RSocketRequester { return new DefaultRSocketRequesterBuilder(); } + // For now we treat metadata as a simple string that is the route. + // This will change after the resolution of: + // https://github.com/rsocket/rsocket-java/issues/568 + + /** + * Entry point to prepare a new request to the given route. + * + *
For requestChannel interactions, i.e. Flux-to-Flux the metadata is + * attached to the first request payload. + * + * @param route the routing destination + * @return a spec for further defining and executing the reuqest + */ + RequestSpec route(String route); + /** * A mutable builder for creating a client {@link RSocketRequester}. */ @@ -90,7 +105,7 @@ public interface RSocketRequester { /** * Configure the {@code ClientTransport} for the RSocket connection - * and connect to the RSocket server + * and connect to the RSocket server. * @param transport the chosen client transport * @return a mono containing the connected {@code RSocketRequester} */ @@ -98,7 +113,7 @@ public interface RSocketRequester { /** * Connect to the RSocket server over TCP transport using the - * provided connection parameters + * provided connection parameters. * @param host the RSocket server host * @param port the RSocket server port * @param dataMimeType the data MimeType @@ -108,7 +123,7 @@ public interface RSocketRequester { /** * Connect to the RSocket server over WebSocket transport using the - * provided connection parameters + * provided connection parameters. * @param uri the RSocket server endpoint URI * @param dataMimeType the data MimeType * @return a mono containing the connected {@code RSocketRequester} @@ -117,21 +132,6 @@ public interface RSocketRequester { } - // For now we treat metadata as a simple string that is the route. - // This will change after the resolution of: - // https://github.com/rsocket/rsocket-java/issues/568 - - /** - * Entry point to prepare a new request to the given route. - * - *
For requestChannel interactions, i.e. Flux-to-Flux the metadata is - * attached to the first request payload. - * - * @param route the routing destination - * @return a spec for further defining and executing the reuqest - */ - RequestSpec route(String route); - /** * Contract to provide input data for an RSocket request.