Index

A C D E F G H I M O P R S T V 
All Classes|All Packages

A

AbstractRSocketConnector - Class in org.springframework.integration.rsocket
A base connector container for common RSocket client and server functionality.
AbstractRSocketConnector(IntegrationRSocketMessageHandler) - Constructor for class org.springframework.integration.rsocket.AbstractRSocketConnector
 
addEndpoint(IntegrationRSocketEndpoint) - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
Add an IntegrationRSocketEndpoint for mapping and handling RSocket requests.
afterPropertiesSet() - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
 
afterPropertiesSet() - Method in class org.springframework.integration.rsocket.ClientRSocketConnector
 
afterPropertiesSet() - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
 
afterSingletonsInstantiated() - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
 
afterSingletonsInstantiated() - Method in class org.springframework.integration.rsocket.ClientRSocketConnector
 
afterSingletonsInstantiated() - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
 

C

clientRSocketConnector(ClientRSocketConnector) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Configure a ClientRSocketConnector for client side requests based on the connection provided by the ClientRSocketConnector.getRequester().
ClientRSocketConnector - Class in org.springframework.integration.rsocket
A client AbstractRSocketConnector extension to the RSocket connection.
ClientRSocketConnector(ClientTransport) - Constructor for class org.springframework.integration.rsocket.ClientRSocketConnector
Instantiate a connector based on the provided ClientTransport.
ClientRSocketConnector(String, int) - Constructor for class org.springframework.integration.rsocket.ClientRSocketConnector
Instantiate a connector based on the TcpClientTransport.
ClientRSocketConnector(URI) - Constructor for class org.springframework.integration.rsocket.ClientRSocketConnector
Instantiate a connector based on the WebsocketClientTransport.
connect() - Method in class org.springframework.integration.rsocket.ClientRSocketConnector
Perform subscription into the RSocket server for incoming requests.

D

decodeFluxAsUnit(boolean) - Method in class org.springframework.integration.rsocket.dsl.RSocketInboundGatewaySpec
Configure an option to decode an incoming Flux as a single unit or each its event separately.
destroy() - Method in class org.springframework.integration.rsocket.ClientRSocketConnector
 
destroy() - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
 
doInit() - Method in class org.springframework.integration.rsocket.outbound.RSocketOutboundGateway
 
doPostProcess(BeanDefinitionBuilder, Element) - Method in class org.springframework.integration.rsocket.config.RSocketInboundGatewayParser
 
doStart() - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
 
doStart() - Method in class org.springframework.integration.rsocket.ClientRSocketConnector
 
doStart() - Method in class org.springframework.integration.rsocket.inbound.RSocketInboundGateway
 
doStart() - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
 

E

expectedResponseType(Class<?>) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Specify the expected response type for the RSocket response.
expectedResponseType(String) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Specify the Expression to determine the type for the RSocket response.
expectedResponseType(Function<Message<P>, ?>) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Specify the Function to determine the type for the RSocket response.
expectedResponseType(Expression) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Specify an Expression to determine the type for the RSocket response.

F

fireAndForget - org.springframework.integration.rsocket.RSocketInteractionModel
The model for RSocket.fireAndForget(io.rsocket.Payload) operation.

G

getBeanClass(Element) - Method in class org.springframework.integration.rsocket.config.RSocketInboundGatewayParser
 
getBoundPort() - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
Return the port this internal server is bound or empty Mono.
getClientRSocketRequester(Object) - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
Return connected RSocketRequester mapped by key or null.
getClientRSocketRequester(Object) - Method in class org.springframework.integration.rsocket.ServerRSocketMessageHandler
Obtain a connected RSocketRequester mapped by provided key or null.
getClientRSocketRequesters() - Method in class org.springframework.integration.rsocket.ServerRSocketConnector
Return connected RSocketRequesters mapped by keys.
getClientRSocketRequesters() - Method in class org.springframework.integration.rsocket.ServerRSocketMessageHandler
Get connected RSocketRequesters mapped by the keys from the connect messages.
getData() - Method in class org.springframework.integration.rsocket.RSocketConnectedEvent
 
getDataMimeType() - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
 
getFrameType() - Method in enum org.springframework.integration.rsocket.RSocketInteractionModel
 
getHeaders() - Method in class org.springframework.integration.rsocket.RSocketConnectedEvent
 
getInputChannelAttributeName() - Method in class org.springframework.integration.rsocket.config.RSocketOutboundGatewayParser
 
getInteractionModels() - Method in class org.springframework.integration.rsocket.inbound.RSocketInboundGateway
 
getInteractionModels() - Method in interface org.springframework.integration.rsocket.IntegrationRSocketEndpoint
Obtain RSocketInteractionModels this ReactiveMessageHandler is going to be mapped onto.
getMetadataMimeType() - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
 
getPath() - Method in class org.springframework.integration.rsocket.inbound.RSocketInboundGateway
Get an array of the path patterns this endpoint is mapped onto.
getPath() - Method in interface org.springframework.integration.rsocket.IntegrationRSocketEndpoint
Obtain path patterns this ReactiveMessageHandler is going to be mapped onto.
getRequester() - Method in class org.springframework.integration.rsocket.ClientRSocketConnector
Return the RSocketRequester this connector is built on.
getRequester() - Method in class org.springframework.integration.rsocket.RSocketConnectedEvent
 
getRSocketRequester() - Method in class org.springframework.integration.rsocket.ClientRSocketConnector
Deprecated.
getRSocketStrategies() - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
 

H

handleMessage(Message<?>) - Method in class org.springframework.integration.rsocket.inbound.RSocketInboundGateway
 
handleRequestMessage(Message<?>) - Method in class org.springframework.integration.rsocket.outbound.RSocketOutboundGateway
 

I

inboundGateway(String...) - Static method in class org.springframework.integration.rsocket.dsl.RSockets
Create an RSocketInboundGatewaySpec builder for request-reply reactive gateway based on the provided path array for mapping.
init() - Method in class org.springframework.integration.rsocket.config.RSocketNamespaceHandler
 
IntegrationRSocketEndpoint - Interface in org.springframework.integration.rsocket
A marker ReactiveMessageHandler extension interface for Spring Integration inbound endpoints.
interactionModel(String) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Configure a SpEL expression to evaluate an RSocketInteractionModel for the RSocket request type at runtime against a request message.
interactionModel(Function<Message<P>, ?>) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Configure a Function to evaluate an RSocketInteractionModel for the RSocket request type at runtime against a request message.
interactionModel(Expression) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Configure a SpEL expression to evaluate an RSocketInteractionModel for the RSocket request type at runtime against a request message.
interactionModel(RSocketInteractionModel) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Configure an RSocketInteractionModel for the RSocket request type.
interactionModels(RSocketInteractionModel...) - Method in class org.springframework.integration.rsocket.dsl.RSocketInboundGatewaySpec
Configure a set of RSocketInteractionModel the endpoint is going to be mapped onto.
isAutoStartup() - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
 
isEligibleAttribute(String) - Method in class org.springframework.integration.rsocket.config.RSocketInboundGatewayParser
 
isRunning() - Method in class org.springframework.integration.rsocket.AbstractRSocketConnector
 

M

metadata(String) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Configure a SpEL expression to evaluate a metadata as a Map<Object, MimeType> for the RSocket request against request message.
metadata(Function<Message<P>, Map<Object, MimeType>>) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Configure a Function to evaluate a metadata as a Map<Object, MimeType> for RSocket request against request message.
metadata(Expression) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Configure a SpEL expression to evaluate a metadata as a Map<Object, MimeType> for the RSocket request type at runtime against a request message.

O

onInit() - Method in class org.springframework.integration.rsocket.inbound.RSocketInboundGateway
 
org.springframework.integration.rsocket - package org.springframework.integration.rsocket
Provides common classes for RSocket components.
org.springframework.integration.rsocket.config - package org.springframework.integration.rsocket.config
Provides classes for RSocket XML namespace parsing and configuration support.
org.springframework.integration.rsocket.dsl - package org.springframework.integration.rsocket.dsl
Provides RSocket Components support for Spring Integration Java DSL.
org.springframework.integration.rsocket.inbound - package org.springframework.integration.rsocket.inbound
Provides classes representing inbound RSocket components.
org.springframework.integration.rsocket.outbound - package org.springframework.integration.rsocket.outbound
Provides classes representing outbound RSocket components.
outboundGateway(String, Object...) - Static method in class org.springframework.integration.rsocket.dsl.RSockets
Create an RSocketOutboundGatewaySpec builder for request-reply gateway based on provided route and optional variables to expand route template.
outboundGateway(Function<Message<P>, ?>) - Static method in class org.springframework.integration.rsocket.dsl.RSockets
Create an RSocketOutboundGatewaySpec builder for request-reply gateway based on provided Function to evaluate target route against request message.
outboundGateway(Expression) - Static method in class org.springframework.integration.rsocket.dsl.RSockets
Create an RSocketOutboundGatewaySpec builder for request-reply gateway based on provided SpEL Expression to evaluate target route against request message.

P

parseHandler(Element, ParserContext) - Method in class org.springframework.integration.rsocket.config.RSocketOutboundGatewayParser
 
publisherElementType(Class<?>) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Configure a type for a request Publisher elements.
publisherElementType(String) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Configure a SpEL expression to evaluate a request Publisher elements type at runtime against a request message.
publisherElementType(Function<Message<P>, ?>) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Configure a Function to evaluate a request Publisher elements type at runtime against a request message.
publisherElementType(Expression) - Method in class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
Configure a SpEL expression to evaluate a request Publisher elements type at runtime against a request message.

R

requestChannel - org.springframework.integration.rsocket.RSocketInteractionModel
The model for RSocket.requestChannel(org.reactivestreams.Publisher<io.rsocket.Payload>) operation.
requestElementType(ResolvableType) - Method in class org.springframework.integration.rsocket.dsl.RSocketInboundGatewaySpec
Specify a type of payload to be generated when the inbound RSocket request content is read by the converters/encoders.
requestResponse - org.springframework.integration.rsocket.RSocketInteractionModel
The model for RSocket.requestResponse(io.rsocket.Payload) operation.
requestStream - org.springframework.integration.rsocket.RSocketInteractionModel
The model for RSocket.requestStream(io.rsocket.Payload) operation.
RSocketConnectedEvent - Class in org.springframework.integration.rsocket
An IntegrationEvent to indicate that RSocket from the client is connected to the server.
RSocketConnectedEvent(Object, Map<String, Object>, DataBuffer, RSocketRequester) - Constructor for class org.springframework.integration.rsocket.RSocketConnectedEvent
 
rsocketConnector(AbstractRSocketConnector) - Method in class org.springframework.integration.rsocket.dsl.RSocketInboundGatewaySpec
Provide an AbstractRSocketConnector reference for an explicit endpoint mapping.
RSocketInboundGateway - Class in org.springframework.integration.rsocket.inbound
The MessagingGatewaySupport implementation for the IntegrationRSocketEndpoint.
RSocketInboundGateway(String...) - Constructor for class org.springframework.integration.rsocket.inbound.RSocketInboundGateway
Instantiate based on the provided path patterns to map this endpoint for incoming RSocket requests.
RSocketInboundGatewayParser - Class in org.springframework.integration.rsocket.config
Parser for the <inbound-gateway/> element of the 'rsocket' namespace.
RSocketInboundGatewayParser() - Constructor for class org.springframework.integration.rsocket.config.RSocketInboundGatewayParser
 
RSocketInboundGatewaySpec - Class in org.springframework.integration.rsocket.dsl
The MessagingGatewaySpec implementation for the RSocketInboundGateway.
RSocketInboundGatewaySpec(String...) - Constructor for class org.springframework.integration.rsocket.dsl.RSocketInboundGatewaySpec
 
RSocketInteractionModel - Enum in org.springframework.integration.rsocket
The RSocket protocol interaction models.
rSocketMessageHandler - Variable in class org.springframework.integration.rsocket.AbstractRSocketConnector
 
RSocketNamespaceHandler - Class in org.springframework.integration.rsocket.config
Namespace handler for Spring Integration XML configuration for RSocket support.
RSocketNamespaceHandler() - Constructor for class org.springframework.integration.rsocket.config.RSocketNamespaceHandler
 
RSocketOutboundGateway - Class in org.springframework.integration.rsocket.outbound
An Outbound Messaging Gateway for RSocket requests.
RSocketOutboundGateway(String, Object...) - Constructor for class org.springframework.integration.rsocket.outbound.RSocketOutboundGateway
Instantiate based on the provided RSocket endpoint route and optional variables to expand route template.
RSocketOutboundGateway(Expression) - Constructor for class org.springframework.integration.rsocket.outbound.RSocketOutboundGateway
Instantiate based on the provided SpEL expression to evaluate an RSocket endpoint route at runtime against a request message.
RSocketOutboundGatewayParser - Class in org.springframework.integration.rsocket.config
Parser for the 'outbound-gateway' element of the rsocket namespace.
RSocketOutboundGatewayParser() - Constructor for class org.springframework.integration.rsocket.config.RSocketOutboundGatewayParser
 
RSocketOutboundGatewaySpec - Class in org.springframework.integration.rsocket.dsl
The MessageHandlerSpec implementation for the RSocketOutboundGateway.
RSocketOutboundGatewaySpec(String, Object...) - Constructor for class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
 
RSocketOutboundGatewaySpec(Expression) - Constructor for class org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec
 
RSockets - Class in org.springframework.integration.rsocket.dsl
The RSocket components Factory.
rsocketStrategies(RSocketStrategies) - Method in class org.springframework.integration.rsocket.dsl.RSocketInboundGatewaySpec
Configure an RSocketStrategies instead of a default one.

S

ServerRSocketConnector - Class in org.springframework.integration.rsocket
A server AbstractRSocketConnector extension to accept and manage client RSocket connections.
ServerRSocketConnector(ServerTransport<CloseableChannel>) - Constructor for class org.springframework.integration.rsocket.ServerRSocketConnector
Instantiate a server connector based on the provided ServerTransport.
ServerRSocketConnector(String, int) - Constructor for class org.springframework.integration.rsocket.ServerRSocketConnector
Instantiate a server connector based on the TcpServerTransport.
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(HttpServer) - Constructor for class org.springframework.integration.rsocket.ServerRSocketConnector
Instantiate a server connector based on the WebsocketServerTransport.
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
Configure a ClientRSocketConnector for client side requests based on the connection provided by the ClientRSocketConnector.getRequester().
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
Configure IntegrationRSocketEndpoint instances for mapping and handling requests.
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.
setInteractionModel(RSocketInteractionModel) - Method in class org.springframework.integration.rsocket.outbound.RSocketOutboundGateway
Configure an RSocketInteractionModel for the RSocket request type.
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
Configure a set of RSocketInteractionModel this endpoint is mapped onto.
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
Provide an AbstractRSocketConnector reference for an explicit endpoint mapping.
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
 

T

toString() - Method in class org.springframework.integration.rsocket.RSocketConnectedEvent
 

V

valueOf(String) - Static method in enum org.springframework.integration.rsocket.RSocketInteractionModel
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.springframework.integration.rsocket.RSocketInteractionModel
Returns an array containing the constants of this enum type, in the order they are declared.
A C D E F G H I M O P R S T V 
All Classes|All Packages