Package | Description |
---|---|
org.springframework.messaging.rsocket |
Support for the RSocket protocol.
|
Modifier and Type | Method and Description |
---|---|
RSocketRequester |
RSocketRequester.Builder.tcp(String host,
int port)
Build an
RSocketRequester with an
RSocketClient that connects over TCP to the
given host and port. |
RSocketRequester |
RSocketRequester.Builder.transport(io.rsocket.transport.ClientTransport transport)
Variant of
RSocketRequester.Builder.tcp(String, int) and RSocketRequester.Builder.websocket(URI)
with an already initialized ClientTransport . |
RSocketRequester |
RSocketRequester.Builder.transports(org.reactivestreams.Publisher<List<io.rsocket.loadbalance.LoadbalanceTarget>> targetPublisher,
io.rsocket.loadbalance.LoadbalanceStrategy loadbalanceStrategy)
Build an
RSocketRequester with an
LoadbalanceRSocketClient that will
connect to one of the given targets selected through the given
LoadbalanceRSocketClient . |
RSocketRequester |
RSocketRequester.Builder.websocket(URI uri)
Build an
RSocketRequester with an
RSocketClient that connects over WebSocket to
the given URL. |
static RSocketRequester |
RSocketRequester.wrap(io.rsocket.RSocket rsocket,
MimeType dataMimeType,
MimeType metadataMimeType,
RSocketStrategies strategies)
Wrap an existing
RSocket . |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<RSocketRequester> |
RSocketRequester.Builder.connect(io.rsocket.transport.ClientTransport transport)
Deprecated.
as of 5.3 in favor of
RSocketRequester.Builder.transport(ClientTransport) |
reactor.core.publisher.Mono<RSocketRequester> |
RSocketRequester.Builder.connectTcp(String host,
int port)
Deprecated.
as of 5.3 in favor of
RSocketRequester.Builder.tcp(String, int) |
reactor.core.publisher.Mono<RSocketRequester> |
RSocketRequester.Builder.connectWebSocket(URI uri)
Deprecated.
as of 5.3 in favor of
RSocketRequester.Builder.websocket(URI) |