S - the target AbstractConnectionFactorySpec implementation type.C - the target AbstractConnectionFactory implementation type.public abstract class AbstractConnectionFactorySpec<S extends AbstractConnectionFactorySpec<S,C>,C extends AbstractConnectionFactory>
extends org.springframework.integration.dsl.IntegrationComponentSpec<S,C>
IntegrationComponentSpec for AbstractConnectionFactorys.| Modifier and Type | Method and Description |
|---|---|
S |
deserializer(org.springframework.core.serializer.Deserializer<?> deserializer) |
S |
id(java.lang.String id) |
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) |
public S id(java.lang.String id)
id in class org.springframework.integration.dsl.IntegrationComponentSpec<S extends AbstractConnectionFactorySpec<S,C>,C extends AbstractConnectionFactory>public S soTimeout(int soTimeout)
soTimeout - the timeout socket option.AbstractConnectionFactory.setSoTimeout(int)public S soReceiveBufferSize(int soReceiveBufferSize)
soReceiveBufferSize - the receive buffer size socket option.AbstractConnectionFactory.setSoReceiveBufferSize(int)public S soSendBufferSize(int soSendBufferSize)
soSendBufferSize - the send buffer size socket option.AbstractConnectionFactory.setSoSendBufferSize(int)public S soTcpNoDelay(boolean soTcpNoDelay)
soTcpNoDelay - the TCP no delay socket option (disable Nagle's algorithm).AbstractConnectionFactory.setSoTcpNoDelay(boolean)public S soLinger(int soLinger)
soLinger - the linger socket option.AbstractConnectionFactory.setSoLinger(int)public S soKeepAlive(boolean soKeepAlive)
soKeepAlive - the keep alive socket option.AbstractConnectionFactory.setSoKeepAlive(boolean)public S soTrafficClass(int soTrafficClass)
soTrafficClass - the traffic class socket option.AbstractConnectionFactory.setSoTrafficClass(int)public S taskExecutor(java.util.concurrent.Executor taskExecutor)
taskExecutor - the task executor.AbstractConnectionFactory.setTaskExecutor(Executor)public S deserializer(org.springframework.core.serializer.Deserializer<?> deserializer)
deserializer - the deserializer.AbstractConnectionFactory.setDeserializer(Deserializer)public S serializer(org.springframework.core.serializer.Serializer<?> serializer)
serializer - the serializer.AbstractConnectionFactory.setSerializer(Serializer)public S mapper(TcpMessageMapper mapper)
mapper - the message mapper.AbstractConnectionFactory.setMapper(TcpMessageMapper)public S leaveOpen(boolean leaveOpen)
leaveOpen - true to leave the socket open for additional messages.AbstractConnectionFactory.setLeaveOpen(boolean)public S interceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain)
interceptorFactoryChain - the interceptor factory chain.AbstractConnectionFactory.setInterceptorFactoryChain(TcpConnectionInterceptorFactoryChain)public S lookupHost(boolean lookupHost)
lookupHost - true to reverse lookup the host.AbstractConnectionFactory.setLookupHost(boolean)public S nioHarvestInterval(int nioHarvestInterval)
nioHarvestInterval - the harvest interval when using NIO.AbstractConnectionFactory.setNioHarvestInterval(int)public S readDelay(long readDelay)
readDelay - the read delay.AbstractConnectionFactory.setReadDelay(long)public S tcpSocketSupport(TcpSocketSupport tcpSocketSupport)
tcpSocketSupport - the TcpSocketSupport.AbstractConnectionFactory.setTcpSocketSupport(TcpSocketSupport)