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(ClientTransport transport)
Variant of
RSocketRequester.Builder.tcp(String, int) and RSocketRequester.Builder.websocket(URI)
with an already initialized ClientTransport . |
RSocketRequester |
RSocketRequester.Builder.transports(Publisher<List<LoadbalanceTarget>> targetPublisher,
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(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(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) |