org.springframework.integration.ip.dsl

Class TcpOutboundGatewaySpec

java.lang.Object

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

org.springframework.integration.dsl.MessageHandlerSpec<TcpOutboundGatewaySpec,TcpOutboundGateway>

org.springframework.integration.ip.dsl.TcpOutboundGatewaySpec

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<TcpOutboundGateway>, ComponentsRegistration

public class TcpOutboundGatewaySpec
extends MessageHandlerSpec<TcpOutboundGatewaySpec,TcpOutboundGateway>
implements ComponentsRegistration

A MessageHandlerSpec for TcpOutboundGateways.

Since:

5.0

Author:

Gary Russell, Artem Bilan

Field Summary

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

logger, PARSER, target

Constructor Summary

Constructors

Constructor and Description
TcpOutboundGatewaySpec(AbstractClientConnectionFactory connectionFactoryBean) Construct an instance using an existing spring-managed connection factory.
TcpOutboundGatewaySpec(TcpClientConnectionFactorySpec connectionFactorySpec) Construct an instance using the supplied connection factory spec.

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.Object,java.lang.String>	getComponentsToRegister()
<P> TcpOutboundGatewaySpec	remoteTimeout(java.util.function.Function<org.springframework.messaging.Message<P>,?> remoteTimeoutFunction) Configure a Function that will be invoked at runtime to determine the destination to which a message will be sent.
TcpOutboundGatewaySpec	remoteTimeout(long remoteTimeout)

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

_this, doGet, get, getId, getObject, getObjectType, id, isSingleton

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpOutboundGatewaySpec

public TcpOutboundGatewaySpec(AbstractClientConnectionFactory connectionFactoryBean)

Construct an instance using an existing spring-managed connection factory.

Parameters:

connectionFactoryBean - the spring-managed bean.

TcpOutboundGatewaySpec

public TcpOutboundGatewaySpec(TcpClientConnectionFactorySpec connectionFactorySpec)

Construct an instance using the supplied connection factory spec.

Parameters:

connectionFactorySpec - the spec.

Method Detail

remoteTimeout

public TcpOutboundGatewaySpec remoteTimeout(long remoteTimeout)

Parameters:

remoteTimeout - the remote timeout to set.

Returns:

the spec.

See Also:

TcpOutboundGateway.setRemoteTimeout(long)

remoteTimeout

public <P> TcpOutboundGatewaySpec remoteTimeout(java.util.function.Function<org.springframework.messaging.Message<P>,?> remoteTimeoutFunction)

Configure a Function that will be invoked at runtime to determine the destination to which a message will be sent. Typically used with a Java 8 Lambda expression:

 .remoteTimeout(m -> m.getHeaders().get('rto'))
 
 

Type Parameters:

P - the message payload type.

Parameters:

remoteTimeoutFunction - the function.

Returns:

the spec.

See Also:

TcpOutboundGateway.setRemoteTimeoutExpression(org.springframework.expression.Expression)

getComponentsToRegister

public java.util.Map<java.lang.Object,java.lang.String> getComponentsToRegister()

Specified by:

getComponentsToRegister in interface ComponentsRegistration