- ServerRSocketConnector - Class in org.springframework.integration.rsocket
-
- ServerRSocketConnector(ServerRSocketMessageHandler) - Constructor for class org.springframework.integration.rsocket.ServerRSocketConnector
-
Instantiate a server connector based on a provided
ServerRSocketMessageHandler
with an assumption that RSocket server is created externally as well.
- ServerRSocketConnector(String, int) - Constructor for class org.springframework.integration.rsocket.ServerRSocketConnector
-
Instantiate a server connector based on the TcpServerTransport.
- ServerRSocketConnector(HttpServer) - Constructor for class org.springframework.integration.rsocket.ServerRSocketConnector
-
Instantiate a server connector based on the WebsocketServerTransport.
- ServerRSocketConnector(ServerTransport<CloseableChannel>) - Constructor for class org.springframework.integration.rsocket.ServerRSocketConnector
-
Instantiate a server connector based on the provided ServerTransport.
- ServerRSocketMessageHandler - Class in org.springframework.integration.rsocket
-
An IntegrationRSocketMessageHandler extension for RSocket service side.
- ServerRSocketMessageHandler() - Constructor for class org.springframework.integration.rsocket.ServerRSocketMessageHandler
-
Create an service side RSocket message handler instance for delegating
to
IntegrationRSocketEndpoint beans and collect
RSocketRequesters
from client connections.
- ServerRSocketMessageHandler(boolean) - Constructor for class org.springframework.integration.rsocket.ServerRSocketMessageHandler
-
Create an service side RSocket message handler instance for delegating
to
IntegrationRSocketEndpoint beans and collect
RSocketRequesters
from client connections.
- setApplicationContext(ApplicationContext) - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
-
- setApplicationContext(ApplicationContext) - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
-
- setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
-
- setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.springframework.integration.rsocket.ServerRSocketMessageHandler
-
- setAutoStartup(boolean) - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
-
- setClientRSocketConnector(ClientRSocketConnector) - Method in class org.springframework.integration.rsocket.outbound.RSocketOutboundGateway
-
- setClientRSocketKeyStrategy(BiFunction<Map<String, Object>, DataBuffer, Object>) - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
-
Configure a strategy to determine a key for the client RSocketRequester connected.
- setClientRSocketKeyStrategy(BiFunction<Map<String, Object>, DataBuffer, Object>) - Method in class org.springframework.integration.rsocket.ServerRSocketMessageHandler
-
Configure a BiFunction to extract a key for mapping connected RSocketRequesters.
- setConnectorConfigurer(RSocketConnectorConfigurer) - Method in class org.springframework.integration.rsocket.ClientRSocketConnector
-
Callback to configure the ClientRSocketFactory directly.
- setDataMimeType(MimeType) - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
-
Configure a MimeType for data exchanging.
- setDataMimeType(MimeType) - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
-
- setDecodeFluxAsUnit(boolean) - Method in class org.springframework.integration.rsocket.inbound.RSocketInboundGateway
-
Configure an option to decode an incoming Flux as a single unit or each its event separately.
- setEndpoints(IntegrationRSocketEndpoint...) - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
-
- setExpectedResponseType(Class<?>) - Method in class org.springframework.integration.rsocket.outbound.RSocketOutboundGateway
-
Specify an response type for the RSocket response.
- setExpectedResponseTypeExpression(Expression) - Method in class org.springframework.integration.rsocket.outbound.RSocketOutboundGateway
-
Specify an Expression to determine the type for the RSocket response.
- setFactoryConfigurer(ClientRSocketFactoryConfigurer) - Method in class org.springframework.integration.rsocket.ClientRSocketConnector
-
- setFactoryConfigurer(Consumer<RSocketFactory.ServerRSocketFactory>) - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
-
- setInteractionModel(RSocketInteractionModel) - Method in class org.springframework.integration.rsocket.outbound.RSocketOutboundGateway
-
- setInteractionModelExpression(Expression) - Method in class org.springframework.integration.rsocket.outbound.RSocketOutboundGateway
-
Configure a SpEL expression to evaluate an
RSocketInteractionModel
for the RSocket request type at runtime against a request message.
- setInteractionModels(RSocketInteractionModel...) - Method in class org.springframework.integration.rsocket.inbound.RSocketInboundGateway
-
- setMetadataExpression(Expression) - Method in class org.springframework.integration.rsocket.outbound.RSocketOutboundGateway
-
Specify a SpEL expression to evaluate a metadata for the RSocket request
as Map<Object, MimeType> against a request message.
- setMetadataMimeType(MimeType) - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
-
Configure a MimeType for metadata exchanging.
- setMetadataMimeType(MimeType) - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
-
- setPublisherElementType(Class<?>) - Method in class org.springframework.integration.rsocket.outbound.RSocketOutboundGateway
-
Configure a type for a request Publisher elements.
- setPublisherElementTypeExpression(Expression) - Method in class org.springframework.integration.rsocket.outbound.RSocketOutboundGateway
-
Configure a SpEL expression to evaluate a request Publisher elements type at runtime against
a request message.
- setRequestElementClass(Class<?>) - Method in class org.springframework.integration.rsocket.inbound.RSocketInboundGateway
-
Specify a type of payload to be generated when the inbound RSocket request
content is read by the encoders.
- setRequestElementType(ResolvableType) - Method in class org.springframework.integration.rsocket.inbound.RSocketInboundGateway
-
Specify the type of payload to be generated when the inbound RSocket request
content is read by the converters/encoders.
- setRSocketConnector(AbstractRSocketConnector) - Method in class org.springframework.integration.rsocket.inbound.RSocketInboundGateway
-
- setRSocketStrategies(RSocketStrategies) - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
-
Configure a RSocketStrategies for data encoding/decoding.
- setRSocketStrategies(RSocketStrategies) - Method in class org.springframework.integration.rsocket.inbound.RSocketInboundGateway
-
Configure an RSocketStrategies instead of a default one.
- setRSocketStrategies(RSocketStrategies) - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
-
- setServerConfigurer(Consumer<RSocketServer>) - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
-
Provide a Consumer to configure the RSocketServer.
- setSetupData(Object) - Method in class org.springframework.integration.rsocket.ClientRSocketConnector
-
Set the data for the setup payload.
- setSetupMetadata(Map<Object, MimeType>) - Method in class org.springframework.integration.rsocket.ClientRSocketConnector
-
Add metadata to the setup payload.
- setSetupRoute(String) - Method in class org.springframework.integration.rsocket.ClientRSocketConnector
-
Set the route for the setup payload.
- setSetupRouteVariables(Object...) - Method in class org.springframework.integration.rsocket.ClientRSocketConnector
-
Set the variables for route template to expand with.
- start() - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
-
- stop() - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
-