org.springframework.integration.ip.dsl

Class TcpOutboundGatewaySpec

java.lang.Object

org.springframework.beans.factory.config.AbstractFactoryBean<T>

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

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

org.springframework.integration.ip.dsl.TcpOutboundGatewaySpec

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, DisposableBean, FactoryBean<TcpOutboundGateway>, InitializingBean, Lifecycle, Phased, SmartLifecycle, 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

Modifier and Type	Field and Description
protected AbstractClientConnectionFactory	connectionFactory

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

PARSER, target

Fields inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

logger

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

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

OBJECT_TYPE_ATTRIBUTE

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
TcpOutboundGatewaySpec	async(boolean async) Set to true to release the sending thread and receive the reply asynchronously.
TcpOutboundGatewaySpec	closeStreamAfterSend(boolean closeStreamAfterSend) Set to true to close the connection output stream after sending without closing the connection.
Map<Object,String>	getComponentsToRegister()
<P> TcpOutboundGatewaySpec	remoteTimeout(java.util.function.Function<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)
TcpOutboundGatewaySpec	unsolictedMessageChannelName(MessageChannel channel) Set the unsolicited message channel.
TcpOutboundGatewaySpec	unsolictedMessageChannelName(String channelName) Set the unsolicited message channel name.

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

_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton

Methods inherited from class java.lang.Object

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

Field Detail

connectionFactory

protected final AbstractClientConnectionFactory connectionFactory

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<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)

closeStreamAfterSend

public TcpOutboundGatewaySpec closeStreamAfterSend(boolean closeStreamAfterSend)

Set to true to close the connection output stream after sending without closing the connection. Use to signal EOF to the server, such as when using a ByteArrayRawSerializer. Requires a single-use connection factory.

Parameters:

closeStreamAfterSend - true to close.

Returns:

the spec.

Since:

5.2

async

public TcpOutboundGatewaySpec async(boolean async)

Set to true to release the sending thread and receive the reply asynchronously.

Parameters:

async - true for asynchronous request/reply.

Returns:

the spec.

Since:

5.3

unsolictedMessageChannelName

public TcpOutboundGatewaySpec unsolictedMessageChannelName(String channelName)

Set the unsolicited message channel name.

Parameters:

channelName - the name.

Returns:

the spec.

Since:

5.4

unsolictedMessageChannelName

public TcpOutboundGatewaySpec unsolictedMessageChannelName(MessageChannel channel)

Set the unsolicited message channel.

Parameters:

channel - the channel.

Returns:

the spec.

Since:

5.4

getComponentsToRegister

public Map<Object,String> getComponentsToRegister()

Specified by:

getComponentsToRegister in interface ComponentsRegistration