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:

org.springframework.beans.factory.FactoryBean<C>

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

Field Summary

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

logger, PARSER, target

Method Summary

Modifier and Type	Method and Description
S	deserializer(org.springframework.core.serializer.Deserializer<?> deserializer)
S	id(java.lang.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(org.springframework.core.serializer.Serializer<?> serializer)
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(java.util.concurrent.Executor taskExecutor)
S	tcpSocketSupport(TcpSocketSupport tcpSocketSupport)

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

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

Methods inherited from class java.lang.Object

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

Method Detail

id

public S id(java.lang.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(java.util.concurrent.Executor taskExecutor)

Parameters:

taskExecutor - the task executor.

Returns:

the spec.

See Also:

AbstractConnectionFactory.setTaskExecutor(Executor)

deserializer

public S deserializer(org.springframework.core.serializer.Deserializer<?> deserializer)

Parameters:

deserializer - the deserializer.

Returns:

the spec.

See Also:

AbstractConnectionFactory.setDeserializer(Deserializer)

serializer

public S serializer(org.springframework.core.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

public S tcpSocketSupport(TcpSocketSupport tcpSocketSupport)

Parameters:

tcpSocketSupport - the TcpSocketSupport.

Returns:

the spec.

See Also:

AbstractConnectionFactory.setTcpSocketSupport(TcpSocketSupport)