Package org.springframework.integration.rsocket.dsl

Class RSocketOutboundGatewaySpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,H>

org.springframework.integration.dsl.MessageHandlerSpec<RSocketOutboundGatewaySpec,RSocketOutboundGateway>

org.springframework.integration.rsocket.dsl.RSocketOutboundGatewaySpec

All Implemented Interfaces:

DisposableBean, FactoryBean<RSocketOutboundGateway>, InitializingBean, Lifecycle, Phased, SmartLifecycle

public class RSocketOutboundGatewaySpec
extends MessageHandlerSpec<RSocketOutboundGatewaySpec,RSocketOutboundGateway>

The MessageHandlerSpec implementation for the RSocketOutboundGateway.

Since:

5.2

Author:

Artem Bilan

Field Summary

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

logger, PARSER, target

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RSocketOutboundGatewaySpec(String route, Object... routeVariables)
protected	RSocketOutboundGatewaySpec(Expression routeExpression)

Method Summary

Modifier and Type	Method	Description
RSocketOutboundGatewaySpec	clientRSocketConnector(ClientRSocketConnector clientRSocketConnector)	Configure a ClientRSocketConnector for client side requests based on the connection provided by the ClientRSocketConnector.getRequester().
RSocketOutboundGatewaySpec	expectedResponseType(Class<?> expectedResponseType)	Specify the expected response type for the RSocket response.
RSocketOutboundGatewaySpec	expectedResponseType(String expectedResponseTypeExpression)	Specify the Expression to determine the type for the RSocket response.
<P> RSocketOutboundGatewaySpec	expectedResponseType(Function<Message<P>,?> expectedResponseTypeFunction)	Specify the Function to determine the type for the RSocket response.
RSocketOutboundGatewaySpec	expectedResponseType(Expression expectedResponseTypeExpression)	Specify an Expression to determine the type for the RSocket response.
RSocketOutboundGatewaySpec	interactionModel(String interactionModelExpression)	Configure a SpEL expression to evaluate an RSocketInteractionModel for the RSocket request type at runtime against a request message.
<P> RSocketOutboundGatewaySpec	interactionModel(Function<Message<P>,?> interactionModelFunction)	Configure a Function to evaluate an RSocketInteractionModel for the RSocket request type at runtime against a request message.
RSocketOutboundGatewaySpec	interactionModel(Expression interactionModelExpression)	Configure a SpEL expression to evaluate an RSocketInteractionModel for the RSocket request type at runtime against a request message.
RSocketOutboundGatewaySpec	interactionModel(RSocketInteractionModel interactionModel)	Configure an RSocketInteractionModel for the RSocket request type.
RSocketOutboundGatewaySpec	metadata(String metadataExpression)	Configure a SpEL expression to evaluate a metadata as a Map<Object, MimeType> for the RSocket request against request message.
<P> RSocketOutboundGatewaySpec	metadata(Function<Message<P>,Map<Object,MimeType>> metadataFunction)	Configure a Function to evaluate a metadata as a Map<Object, MimeType> for RSocket request against request message.
RSocketOutboundGatewaySpec	metadata(Expression metadataExpression)	Configure a SpEL expression to evaluate a metadata as a Map<Object, MimeType> for the RSocket request type at runtime against a request message.
RSocketOutboundGatewaySpec	publisherElementType(Class<?> publisherElementType)	Configure a type for a request Publisher elements.
RSocketOutboundGatewaySpec	publisherElementType(String publisherElementTypeExpression)	Configure a SpEL expression to evaluate a request Publisher elements type at runtime against a request message.
<P> RSocketOutboundGatewaySpec	publisherElementType(Function<Message<P>,?> publisherElementTypeFunction)	Configure a Function to evaluate a request Publisher elements type at runtime against a request message.
RSocketOutboundGatewaySpec	publisherElementType(Expression publisherElementTypeExpression)	Configure a SpEL expression to evaluate a request Publisher elements type at runtime against a request message.

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, afterPropertiesSet, destroy, doGet, get, getId, getObject, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.beans.factory.FactoryBean

isSingleton

Constructor Details

RSocketOutboundGatewaySpec

protected RSocketOutboundGatewaySpec(String route,
 Object... routeVariables)

RSocketOutboundGatewaySpec

protected RSocketOutboundGatewaySpec(Expression routeExpression)

Method Details

clientRSocketConnector

public RSocketOutboundGatewaySpec clientRSocketConnector(ClientRSocketConnector clientRSocketConnector)

Configure a ClientRSocketConnector for client side requests based on the connection provided by the ClientRSocketConnector.getRequester().

Parameters:

clientRSocketConnector - the ClientRSocketConnector to use.

Returns:

the spec

See Also:

• RSocketOutboundGateway.setClientRSocketConnector(ClientRSocketConnector)

interactionModel

public RSocketOutboundGatewaySpec interactionModel(RSocketInteractionModel interactionModel)

Configure an RSocketInteractionModel for the RSocket request type.

Parameters:

interactionModel - the RSocketInteractionModel to use.

Returns:

the spec

Since:

5.2.2

See Also:

• RSocketOutboundGateway.setInteractionModel(RSocketInteractionModel)

interactionModel

public <P> RSocketOutboundGatewaySpec interactionModel(Function<Message<P>,?> interactionModelFunction)

Configure a Function to evaluate an RSocketInteractionModel for the RSocket request type at runtime against a request message.

Type Parameters:

P - the expected request message payload type.

Parameters:

interactionModelFunction - the Function to use.

Returns:

the spec

Since:

5.2.2

See Also:

• RSocketOutboundGateway.setInteractionModelExpression(Expression)

interactionModel

public RSocketOutboundGatewaySpec interactionModel(String interactionModelExpression)

Configure a SpEL expression to evaluate an RSocketInteractionModel for the RSocket request type at runtime against a request message.

Parameters:

interactionModelExpression - the SpEL expression to use.

Returns:

the spec

Since:

5.2.2

See Also:

• RSocketOutboundGateway.setInteractionModelExpression(Expression)

interactionModel

public RSocketOutboundGatewaySpec interactionModel(Expression interactionModelExpression)

Configure a SpEL expression to evaluate an RSocketInteractionModel for the RSocket request type at runtime against a request message.

Parameters:

interactionModelExpression - the SpEL expression to use.

Returns:

the spec

Since:

5.2.2

See Also:

• RSocketOutboundGateway.setInteractionModelExpression(Expression)

publisherElementType

public RSocketOutboundGatewaySpec publisherElementType(Class<?> publisherElementType)

Configure a type for a request Publisher elements.

Parameters:

publisherElementType - the type of the request Publisher elements.

Returns:

the spec

See Also:

• RSocketOutboundGateway.setPublisherElementType(Class)

publisherElementType

public <P> RSocketOutboundGatewaySpec publisherElementType(Function<Message<P>,?> publisherElementTypeFunction)

Configure a Function to evaluate a request Publisher elements type at runtime against a request message.

Type Parameters:

P - the expected request message payload type.

Parameters:

publisherElementTypeFunction - the Function to evaluate a type for the request Publisher elements.

Returns:

the spec

See Also:

• RSocketOutboundGateway.setPublisherElementTypeExpression(Expression)

publisherElementType

public RSocketOutboundGatewaySpec publisherElementType(String publisherElementTypeExpression)

Configure a SpEL expression to evaluate a request Publisher elements type at runtime against a request message.

Parameters:

publisherElementTypeExpression - the expression to evaluate a type for the request Publisher elements.

Returns:

the spec

See Also:

• RSocketOutboundGateway.setPublisherElementTypeExpression(Expression)

publisherElementType

public RSocketOutboundGatewaySpec publisherElementType(Expression publisherElementTypeExpression)

Configure a SpEL expression to evaluate a request Publisher elements type at runtime against a request message.

Parameters:

publisherElementTypeExpression - the expression to evaluate a type for the request Publisher elements.

Returns:

the spec

See Also:

• RSocketOutboundGateway.setPublisherElementTypeExpression(Expression)

expectedResponseType

public RSocketOutboundGatewaySpec expectedResponseType(Class<?> expectedResponseType)

Specify the expected response type for the RSocket response.

Parameters:

expectedResponseType - The expected type.

Returns:

the spec

See Also:

• RSocketOutboundGateway.setExpectedResponseType(Class)

expectedResponseType

public <P> RSocketOutboundGatewaySpec expectedResponseType(Function<Message<P>,?> expectedResponseTypeFunction)

Specify the Function to determine the type for the RSocket response.

Type Parameters:

P - the expected request message payload type.

Parameters:

expectedResponseTypeFunction - The expected response type Function.

Returns:

the spec

See Also:

• RSocketOutboundGateway.setExpectedResponseTypeExpression(Expression)

expectedResponseType

public RSocketOutboundGatewaySpec expectedResponseType(String expectedResponseTypeExpression)

Specify the Expression to determine the type for the RSocket response.

Parameters:

expectedResponseTypeExpression - The expected response type expression.

Returns:

the spec

See Also:

• RSocketOutboundGateway.setExpectedResponseTypeExpression(Expression)

expectedResponseType

public RSocketOutboundGatewaySpec expectedResponseType(Expression expectedResponseTypeExpression)

Specify an Expression to determine the type for the RSocket response.

Parameters:

expectedResponseTypeExpression - The expected response type expression.

Returns:

the spec

See Also:

• RSocketOutboundGateway.setExpectedResponseTypeExpression(Expression)

metadata

public <P> RSocketOutboundGatewaySpec metadata(Function<Message<P>,Map<Object,MimeType>> metadataFunction)

Configure a Function to evaluate a metadata as a Map<Object, MimeType> for RSocket request against request message.

Type Parameters:

P - the expected request message payload type.

Parameters:

metadataFunction - the Function to use.

Returns:

the spec

See Also:

• RSocketOutboundGateway.setMetadataExpression(Expression)

metadata

public RSocketOutboundGatewaySpec metadata(String metadataExpression)

Configure a SpEL expression to evaluate a metadata as a Map<Object, MimeType> for the RSocket request against request message.

Parameters:

metadataExpression - the SpEL expression to use.

Returns:

the spec

See Also:

• RSocketOutboundGateway.setMetadataExpression(Expression)

metadata

public RSocketOutboundGatewaySpec metadata(Expression metadataExpression)

Configure a SpEL expression to evaluate a metadata as a Map<Object, MimeType> for the RSocket request type at runtime against a request message.

Parameters:

metadataExpression - the SpEL expression to use.

Returns:

the spec

See Also:

• RSocketOutboundGateway.setMetadataExpression(Expression)