Uses of Interface
org.springframework.messaging.rsocket.RSocketRequester
Package
Description
Support for the RSocket protocol.
Annotations to declare an RSocket service contract with request methods along
with a proxy factory backed by an
RSocketRequester
.-
Uses of RSocketRequester in org.springframework.messaging.rsocket
Modifier and TypeMethodDescriptionBuild anRSocketRequester
with anRSocketClient
that connects over TCP to the given host and port.RSocketRequester.Builder.transport
(ClientTransport transport) Variant ofRSocketRequester.Builder.tcp(String, int)
andRSocketRequester.Builder.websocket(URI)
with an already initializedClientTransport
.RSocketRequester.Builder.transports
(Publisher<List<LoadbalanceTarget>> targetPublisher, LoadbalanceStrategy loadbalanceStrategy) Build anRSocketRequester
with anLoadbalanceRSocketClient
that will connect to one of the given targets selected through the givenLoadbalanceRSocketClient
.Build anRSocketRequester
with anRSocketClient
that connects over WebSocket to the given URL.static RSocketRequester
RSocketRequester.wrap
(RSocket rsocket, MimeType dataMimeType, MimeType metadataMimeType, RSocketStrategies strategies) Wrap an existingRSocket
.Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<RSocketRequester>
RSocketRequester.Builder.connect
(ClientTransport transport) Deprecated.reactor.core.publisher.Mono<RSocketRequester>
RSocketRequester.Builder.connectTcp
(String host, int port) Deprecated.as of 5.3 in favor ofRSocketRequester.Builder.tcp(String, int)
reactor.core.publisher.Mono<RSocketRequester>
RSocketRequester.Builder.connectWebSocket
(URI uri) Deprecated.as of 5.3 in favor ofRSocketRequester.Builder.websocket(URI)
-
Uses of RSocketRequester in org.springframework.messaging.rsocket.service
Modifier and TypeMethodDescriptionRSocketServiceProxyFactory.builder
(RSocketRequester requester) Return anRSocketServiceProxyFactory
builder, initialized with the given client.RSocketServiceProxyFactory.Builder.rsocketRequester
(RSocketRequester requester) Provide the requester to perform requests through.
RSocketRequester.Builder.transport(ClientTransport)