Package org.springframework.integration.ip.dsl

Class AbstractConnectionFactorySpec<S extends AbstractConnectionFactorySpec<S,C>,C extends AbstractConnectionFactory>

java.lang.Object

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

org.springframework.integration.ip.dsl.AbstractConnectionFactorySpec<S,C>

Type Parameters:

S - the target AbstractConnectionFactorySpec implementation type.

C - the target AbstractConnectionFactory implementation type.

All Implemented Interfaces:

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

Direct Known Subclasses:

TcpClientConnectionFactorySpec, TcpServerConnectionFactorySpec

public abstract class AbstractConnectionFactorySpec<S extends AbstractConnectionFactorySpec<S,C>,C extends AbstractConnectionFactory>
extends IntegrationComponentSpec<S,C>

An IntegrationComponentSpec for AbstractConnectionFactorys.

Since:

5.0

Author:

Gary Russell, 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	AbstractConnectionFactorySpec(C connectionFactory)

Method Summary

Modifier and Type	Method	Description
S	deserializer(Deserializer<?> deserializer)
S	id(String id)	Configure the component identifier.
S	interceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain)
S	leaveOpen(boolean leaveOpen)
S	lookupHost(boolean lookupHost)
S	mapper(TcpMessageMapper mapper)
S	nioHarvestInterval(int nioHarvestInterval)
S	readDelay(long readDelay)
S	serializer(Serializer<?> serializer)
S	singleUseConnections(boolean single)	This connection factory uses a new connection for each operation.
S	socketSupport(TcpSocketSupport tcpSocketSupport)
S	soKeepAlive(boolean soKeepAlive)
S	soLinger(int soLinger)
S	soReceiveBufferSize(int soReceiveBufferSize)
S	soSendBufferSize(int soSendBufferSize)
S	soTcpNoDelay(boolean soTcpNoDelay)
S	soTimeout(int soTimeout)
S	soTrafficClass(int soTrafficClass)
S	taskExecutor(Executor taskExecutor)
S	tcpSocketSupport(TcpSocketSupport tcpSocketSupport)	Deprecated. in favor of socketSupport(TcpSocketSupport).

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

_this, afterPropertiesSet, destroy, doGet, get, getId, getObject, getObjectType, getPhase, 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

AbstractConnectionFactorySpec

protected AbstractConnectionFactorySpec(C connectionFactory)

Method Details

id

public S id(String id)

Description copied from class: IntegrationComponentSpec

Configure the component identifier. Used as the beanName to register the bean in the application context for this component.

Overrides:

id in class IntegrationComponentSpec<S extends AbstractConnectionFactorySpec<S,C>,C extends AbstractConnectionFactory>

Parameters:

id - the id.

Returns:

the spec.

soTimeout

public S soTimeout(int soTimeout)

Parameters:

soTimeout - the timeout socket option.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setSoTimeout(int)

soReceiveBufferSize

public S soReceiveBufferSize(int soReceiveBufferSize)

Parameters:

soReceiveBufferSize - the receive buffer size socket option.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setSoReceiveBufferSize(int)

soSendBufferSize

public S soSendBufferSize(int soSendBufferSize)

Parameters:

soSendBufferSize - the send buffer size socket option.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setSoSendBufferSize(int)

soTcpNoDelay

public S soTcpNoDelay(boolean soTcpNoDelay)

Parameters:

soTcpNoDelay - the TCP no delay socket option (disable Nagle's algorithm).

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setSoTcpNoDelay(boolean)

soLinger

public S soLinger(int soLinger)

Parameters:

soLinger - the linger socket option.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setSoLinger(int)

soKeepAlive

public S soKeepAlive(boolean soKeepAlive)

Parameters:

soKeepAlive - the keep alive socket option.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setSoKeepAlive(boolean)

soTrafficClass

public S soTrafficClass(int soTrafficClass)

Parameters:

soTrafficClass - the traffic class socket option.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setSoTrafficClass(int)

taskExecutor

public S taskExecutor(Executor taskExecutor)

Parameters:

taskExecutor - the task executor.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setTaskExecutor(Executor)

deserializer

public S deserializer(Deserializer<?> deserializer)

Parameters:

deserializer - the deserializer.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setDeserializer(Deserializer)

serializer

public S serializer(Serializer<?> serializer)

Parameters:

serializer - the serializer.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setSerializer(Serializer)

mapper

public S mapper(TcpMessageMapper mapper)

Parameters:

mapper - the message mapper.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setMapper(TcpMessageMapper)

leaveOpen

public S leaveOpen(boolean leaveOpen)

Parameters:

leaveOpen - true to leave the socket open for additional messages.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setLeaveOpen(boolean)

interceptorFactoryChain

public S interceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain)

Parameters:

interceptorFactoryChain - the interceptor factory chain.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setInterceptorFactoryChain(TcpConnectionInterceptorFactoryChain)

lookupHost

public S lookupHost(boolean lookupHost)

Parameters:

lookupHost - true to reverse lookup the host.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setLookupHost(boolean)

nioHarvestInterval

public S nioHarvestInterval(int nioHarvestInterval)

Parameters:

nioHarvestInterval - the harvest interval when using NIO.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setNioHarvestInterval(int)

readDelay

public S readDelay(long readDelay)

Parameters:

readDelay - the read delay.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setReadDelay(long)

tcpSocketSupport

@Deprecated
public S tcpSocketSupport(TcpSocketSupport tcpSocketSupport)

Deprecated.

in favor of socketSupport(TcpSocketSupport).

Parameters:

tcpSocketSupport - the TcpSocketSupport.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setTcpSocketSupport(TcpSocketSupport)

socketSupport

public S socketSupport(TcpSocketSupport tcpSocketSupport)

Parameters:

tcpSocketSupport - the TcpSocketSupport.

Returns:

the spec.

See Also:

• AbstractConnectionFactory.setTcpSocketSupport(TcpSocketSupport)

singleUseConnections

public S singleUseConnections(boolean single)

This connection factory uses a new connection for each operation.

Parameters:

single - true for a new connection for each operation.

Returns:

the spec.

Since:

5.2