public class TcpInboundChannelAdapterSpec extends MessageProducerSpec<TcpInboundChannelAdapterSpec,TcpReceivingChannelAdapter> implements ComponentsRegistration
Modifier and Type | Field and Description |
---|---|
protected AbstractConnectionFactory |
connectionFactory |
PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
Modifier | Constructor and Description |
---|---|
protected |
TcpInboundChannelAdapterSpec(AbstractConnectionFactory connectionFactoryBean)
Construct an instance using an existing spring-managed connection factory.
|
protected |
TcpInboundChannelAdapterSpec(AbstractConnectionFactorySpec<?,?> connectionFactorySpec)
Construct an instance using the provided connection factory spec.
|
Modifier and Type | Method and Description |
---|---|
TcpInboundChannelAdapterSpec |
clientMode(boolean isClientMode) |
Map<Object,String> |
getComponentsToRegister() |
TcpInboundChannelAdapterSpec |
retryInterval(long retryInterval) |
TcpInboundChannelAdapterSpec |
taskScheduler(TaskScheduler taskScheduler) |
autoStartup, errorChannel, errorChannel, errorMessageStrategy, id, outputChannel, outputChannel, phase, sendTimeout, shouldTrack
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
protected final AbstractConnectionFactory connectionFactory
protected TcpInboundChannelAdapterSpec(AbstractConnectionFactory connectionFactoryBean)
connectionFactoryBean
- the spring-managed bean.protected TcpInboundChannelAdapterSpec(AbstractConnectionFactorySpec<?,?> connectionFactorySpec)
connectionFactorySpec
- the spec.public TcpInboundChannelAdapterSpec clientMode(boolean isClientMode)
isClientMode
- true to connect in client modeTcpReceivingChannelAdapter.setClientMode(boolean)
public TcpInboundChannelAdapterSpec retryInterval(long retryInterval)
retryInterval
- the client mode retry interval to set.TcpReceivingChannelAdapter.setRetryInterval(long)
public TcpInboundChannelAdapterSpec taskScheduler(TaskScheduler taskScheduler)
taskScheduler
- the scheduler for connecting in client mode.IntegrationObjectSupport.setTaskScheduler(TaskScheduler)
public Map<Object,String> getComponentsToRegister()
getComponentsToRegister
in interface ComponentsRegistration