org.springframework.integration.ip.config

Class TcpConnectionFactoryFactoryBean

java.lang.Object

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

org.springframework.integration.ip.config.TcpConnectionFactoryFactoryBean

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, FactoryBean<AbstractConnectionFactory>, InitializingBean, ApplicationEventPublisherAware, Lifecycle, Phased, SmartLifecycle

public class TcpConnectionFactoryFactoryBean
extends AbstractFactoryBean<AbstractConnectionFactory>
implements SmartLifecycle, BeanNameAware, BeanFactoryAware, ApplicationEventPublisherAware

Instantiates a TcpN(et|io)(Server|Client)ConnectionFactory, depending on type and using-nio attributes.

Since:

2.0.5

Author:

Gary Russell

Field Summary

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

logger

Constructor Summary

Constructors

Constructor and Description
TcpConnectionFactoryFactoryBean()

Method Summary

Methods

Modifier and Type	Method and Description
protected AbstractConnectionFactory	createInstance()
Class<?>	getObjectType()
int	getPhase()
boolean	isAutoStartup()
boolean	isRunning()
void	setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
void	setApplySequence(boolean applySequence)
void	setBacklog(int backlog)
void	setBeanFactory(BeanFactory beanFactory)
void	setBeanName(String name)
void	setDeserializer(Deserializer<?> deserializer)
void	setHost(String host)
void	setInterceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain)
void	setLocalAddress(String localAddress)
void	setLookupHost(boolean lookupHost)
void	setMapper(TcpMessageMapper mapper)
void	setNioConnectionSupport(TcpNioConnectionSupport tcpNioSupport) Rare property - not exposed through namespace
void	setPort(int port)
void	setSerializer(Serializer<?> serializer)
void	setSingleUse(boolean singleUse)
void	setSocketFactorySupport(TcpSocketFactorySupport tcpSocketFactorySupport)
void	setSocketSupport(TcpSocketSupport tcpSocketSupport)
void	setSoKeepAlive(boolean soKeepAlive)
void	setSoLinger(int soLinger)
void	setSoReceiveBufferSize(int soReceiveBufferSize)
void	setSoSendBufferSize(int soSendBufferSize)
void	setSoTcpNoDelay(boolean soTcpNoDelay)
void	setSoTimeout(int soTimeout)
void	setSoTrafficClass(int soTrafficClass)
void	setSslContextSupport(TcpSSLContextSupport sslContextSupport)
void	setTaskExecutor(Executor taskExecutor)
void	setType(String type)
void	setUsingDirectBuffers(boolean usingDirectBuffers)
void	setUsingNio(boolean usingNio)
void	start()
void	stop()
void	stop(Runnable callback)

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpConnectionFactoryFactoryBean

public TcpConnectionFactoryFactoryBean()

Method Detail

setBeanFactory

public final void setBeanFactory(BeanFactory beanFactory)

Specified by:

setBeanFactory in interface BeanFactoryAware

Overrides:

setBeanFactory in class AbstractFactoryBean<AbstractConnectionFactory>

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface FactoryBean<AbstractConnectionFactory>

Specified by:

getObjectType in class AbstractFactoryBean<AbstractConnectionFactory>

createInstance

protected AbstractConnectionFactory createInstance()
                                            throws Exception

Specified by:

createInstance in class AbstractFactoryBean<AbstractConnectionFactory>

Throws:

Exception

setPort

public void setPort(int port)

Parameters:

port - the port to set

setHost

public void setHost(String host)

Parameters:

host - the host to set

setType

public void setType(String type)

Parameters:

type - the type to set

setLocalAddress

public void setLocalAddress(String localAddress)

Parameters:

localAddress - The local addres..

See Also:

AbstractServerConnectionFactory.setLocalAddress(java.lang.String)

setSoTimeout

public void setSoTimeout(int soTimeout)

Parameters:

soTimeout - The timeout.

See Also:

AbstractConnectionFactory.setSoTimeout(int)

setSoReceiveBufferSize

public void setSoReceiveBufferSize(int soReceiveBufferSize)

Parameters:

soReceiveBufferSize - The receive buffer size.

See Also:

AbstractConnectionFactory.setSoReceiveBufferSize(int)

setSoSendBufferSize

public void setSoSendBufferSize(int soSendBufferSize)

Parameters:

soSendBufferSize - The send buffer size.

See Also:

AbstractConnectionFactory.setSoSendBufferSize(int)

setSoTcpNoDelay

public void setSoTcpNoDelay(boolean soTcpNoDelay)

Parameters:

soTcpNoDelay - The TCP no delay to set.

See Also:

AbstractConnectionFactory.setSoTcpNoDelay(boolean)

setSoLinger

public void setSoLinger(int soLinger)

Parameters:

soLinger - The SO Linger to set.

See Also:

AbstractConnectionFactory.setSoLinger(int)

setSoKeepAlive

public void setSoKeepAlive(boolean soKeepAlive)

Parameters:

soKeepAlive - The SO keepalive to set.

See Also:

AbstractConnectionFactory.setSoKeepAlive(boolean)

setSoTrafficClass

public void setSoTrafficClass(int soTrafficClass)

Parameters:

soTrafficClass - The SO traffic class to set.

See Also:

AbstractConnectionFactory.setSoTrafficClass(int)

setUsingNio

public void setUsingNio(boolean usingNio)

Parameters:

usingNio - the usingNio to set

setUsingDirectBuffers

public void setUsingDirectBuffers(boolean usingDirectBuffers)

Parameters:

usingDirectBuffers - the usingDirectBuffers to set.

See Also:

TcpNioServerConnectionFactory.setUsingDirectBuffers(boolean)

setTaskExecutor

public void setTaskExecutor(Executor taskExecutor)

Parameters:

taskExecutor - The task executor.

See Also:

AbstractConnectionFactory.setTaskExecutor(java.util.concurrent.Executor)

setDeserializer

public void setDeserializer(Deserializer<?> deserializer)

Parameters:

deserializer - The deserializer.

See Also:

AbstractConnectionFactory.setDeserializer(org.springframework.core.serializer.Deserializer)

setSerializer

public void setSerializer(Serializer<?> serializer)

Parameters:

serializer - The serializer.

See Also:

AbstractConnectionFactory.setSerializer(org.springframework.core.serializer.Serializer)

setMapper

public void setMapper(TcpMessageMapper mapper)

Parameters:

mapper - The mapper.

See Also:

AbstractConnectionFactory.setMapper(org.springframework.integration.ip.tcp.connection.TcpMessageMapper)

setSingleUse

public void setSingleUse(boolean singleUse)

Parameters:

singleUse - The singleUse to set.

See Also:

AbstractConnectionFactory.setSingleUse(boolean)

setBacklog

public void setBacklog(int backlog)

Parameters:

backlog - The backlog.

See Also:

AbstractServerConnectionFactory.setBacklog(int)

setInterceptorFactoryChain

public void setInterceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain)

Parameters:

interceptorFactoryChain - The interceptor factory chain.

See Also:

AbstractConnectionFactory.setInterceptorFactoryChain(org.springframework.integration.ip.tcp.connection.TcpConnectionInterceptorFactoryChain)

setLookupHost

public void setLookupHost(boolean lookupHost)

Parameters:

lookupHost - The lookupHost to set.

See Also:

AbstractConnectionFactory.setLookupHost(boolean)

start

public void start()

Specified by:

start in interface Lifecycle

See Also:

AbstractConnectionFactory.start()

stop

public void stop()

Specified by:

stop in interface Lifecycle

See Also:

AbstractConnectionFactory.stop()

getPhase

public int getPhase()

Specified by:

getPhase in interface Phased

Returns:

phase

See Also:

AbstractConnectionFactory.getPhase()

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface SmartLifecycle

Returns:

isAutoStartup

See Also:

AbstractConnectionFactory.isAutoStartup()

stop

public void stop(Runnable callback)

Specified by:

stop in interface SmartLifecycle

Parameters:

callback - The Runnable to invoke.

See Also:

AbstractConnectionFactory.stop(java.lang.Runnable)

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Lifecycle

setBeanName

public void setBeanName(String name)

Specified by:

setBeanName in interface BeanNameAware

setApplySequence

public void setApplySequence(boolean applySequence)

Parameters:

applySequence - the applySequence to set

setSslContextSupport

public void setSslContextSupport(TcpSSLContextSupport sslContextSupport)

setSocketSupport

public void setSocketSupport(TcpSocketSupport tcpSocketSupport)

setNioConnectionSupport

public void setNioConnectionSupport(TcpNioConnectionSupport tcpNioSupport)

Rare property - not exposed through namespace

Parameters:

tcpNioSupport - The tcpNioSupport to set.

setSocketFactorySupport

public void setSocketFactorySupport(TcpSocketFactorySupport tcpSocketFactorySupport)

setApplicationEventPublisher

public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

Specified by:

setApplicationEventPublisher in interface ApplicationEventPublisherAware