|
Spring Integration | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.springframework.integration.context.IntegrationObjectSupport org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory org.springframework.integration.ip.tcp.connection.AbstractClientConnectionFactory org.springframework.integration.ip.tcp.connection.CachingClientConnectionFactory
public class CachingClientConnectionFactory
Field Summary |
---|
Fields inherited from class org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory |
---|
DEFAULT_REPLY_TIMEOUT, lifecycleMonitor |
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport |
---|
logger |
Constructor Summary | |
---|---|
CachingClientConnectionFactory(AbstractClientConnectionFactory target,
int poolSize)
|
Method Summary | |
---|---|
void |
close()
Closes the server. |
boolean |
equals(java.lang.Object obj)
|
void |
forceClose(TcpConnection connection)
Force close the connection and null the field if it's a shared connection. |
int |
getActiveCount()
|
int |
getAllocatedCount()
|
java.lang.String |
getComponentType()
Subclasses may implement this method to provide component type information. |
org.springframework.core.serializer.Deserializer<?> |
getDeserializer()
|
java.lang.String |
getHost()
|
int |
getIdleCount()
|
TcpListener |
getListener()
|
TcpMessageMapper |
getMapper()
|
int |
getPhase()
|
int |
getPoolSize()
|
int |
getPort()
|
TcpSender |
getSender()
|
org.springframework.core.serializer.Serializer<?> |
getSerializer()
|
int |
getSoLinger()
|
int |
getSoReceiveBufferSize()
|
int |
getSoSendBufferSize()
|
int |
getSoTimeout()
|
int |
getSoTrafficClass()
|
int |
hashCode()
|
boolean |
isAutoStartup()
We are controlled by the startup options of the bound endpoint. |
boolean |
isLookupHost()
|
boolean |
isRunning()
|
boolean |
isSingleUse()
|
boolean |
isSoKeepAlive()
|
boolean |
isSoTcpNoDelay()
|
TcpConnection |
obtainConnection()
|
void |
registerListener(TcpListener listener)
Registers a TcpListener to receive messages after the payload has been converted from the input data. |
void |
registerSender(TcpSender sender)
Registers a TcpSender; for server sockets, used to provide connection information so a sender can be used to reply to incoming messages. |
void |
setComponentName(java.lang.String componentName)
Sets the name of this component. |
void |
setConnectionWaitTimeout(int connectionWaitTimeout)
|
void |
setDeserializer(org.springframework.core.serializer.Deserializer<?> deserializer)
|
void |
setInterceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain)
|
void |
setLookupHost(boolean lookupHost)
If true, DNS reverse lookup is done on the remote ip address. |
void |
setMapper(TcpMessageMapper mapper)
|
void |
setPoolSize(int poolSize)
|
void |
setSerializer(org.springframework.core.serializer.Serializer<?> serializer)
|
void |
setSingleUse(boolean singleUse)
If true, sockets created by this factory will be used once. |
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 |
setTaskExecutor(java.util.concurrent.Executor taskExecutor)
|
void |
start()
|
void |
stop()
Stops the server. |
void |
stop(java.lang.Runnable callback)
|
Methods inherited from class org.springframework.integration.ip.tcp.connection.AbstractClientConnectionFactory |
---|
getConnection, getTheConnection, initializeConnection, setTheConnection |
Methods inherited from class org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory |
---|
addConnection, checkActive, doAccept, getTaskExecutor, getTcpSocketSupport, harvestClosedConnections, isActive, processNioSelections, setActive, setNioHarvestInterval, setSocketAttributes, setTcpSocketSupport, wrapConnection |
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport |
---|
afterPropertiesSet, getBeanFactory, getComponentName, getConversionService, getTaskScheduler, onInit, setBeanFactory, setBeanName, setConversionService, setTaskScheduler, toString |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public CachingClientConnectionFactory(AbstractClientConnectionFactory target, int poolSize)
Method Detail |
---|
public void setConnectionWaitTimeout(int connectionWaitTimeout)
public void setPoolSize(int poolSize)
setPoolSize
in class AbstractConnectionFactory
public int getPoolSize()
getPoolSize
in class AbstractConnectionFactory
public int getIdleCount()
public int getActiveCount()
public int getAllocatedCount()
public TcpConnection obtainConnection() throws java.lang.Exception
obtainConnection
in class AbstractClientConnectionFactory
java.lang.Exception
public boolean isRunning()
isRunning
in interface org.springframework.context.Lifecycle
isRunning
in class AbstractConnectionFactory
public void close()
AbstractConnectionFactory
close
in class AbstractConnectionFactory
public int hashCode()
hashCode
in class java.lang.Object
public void setComponentName(java.lang.String componentName)
IntegrationObjectSupport
setComponentName
in class IntegrationObjectSupport
public java.lang.String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class IntegrationObjectSupport
public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public int getSoTimeout()
getSoTimeout
in class AbstractConnectionFactory
public void setSoTimeout(int soTimeout)
setSoTimeout
in class AbstractConnectionFactory
soTimeout
- the soTimeout to setpublic int getSoReceiveBufferSize()
getSoReceiveBufferSize
in class AbstractConnectionFactory
public void setSoReceiveBufferSize(int soReceiveBufferSize)
setSoReceiveBufferSize
in class AbstractConnectionFactory
soReceiveBufferSize
- the soReceiveBufferSize to setpublic int getSoSendBufferSize()
getSoSendBufferSize
in class AbstractConnectionFactory
public void setSoSendBufferSize(int soSendBufferSize)
setSoSendBufferSize
in class AbstractConnectionFactory
soSendBufferSize
- the soSendBufferSize to setpublic boolean isSoTcpNoDelay()
isSoTcpNoDelay
in class AbstractConnectionFactory
public void setSoTcpNoDelay(boolean soTcpNoDelay)
setSoTcpNoDelay
in class AbstractConnectionFactory
soTcpNoDelay
- the soTcpNoDelay to setpublic int getSoLinger()
getSoLinger
in class AbstractConnectionFactory
public void setSoLinger(int soLinger)
setSoLinger
in class AbstractConnectionFactory
soLinger
- the soLinger to setpublic boolean isSoKeepAlive()
isSoKeepAlive
in class AbstractConnectionFactory
public void setSoKeepAlive(boolean soKeepAlive)
setSoKeepAlive
in class AbstractConnectionFactory
soKeepAlive
- the soKeepAlive to setpublic int getSoTrafficClass()
getSoTrafficClass
in class AbstractConnectionFactory
public void setSoTrafficClass(int soTrafficClass)
setSoTrafficClass
in class AbstractConnectionFactory
soTrafficClass
- the soTrafficClass to setpublic java.lang.String getHost()
getHost
in class AbstractConnectionFactory
public int getPort()
getPort
in class AbstractConnectionFactory
public TcpListener getListener()
getListener
in class AbstractConnectionFactory
public TcpSender getSender()
getSender
in class AbstractConnectionFactory
public org.springframework.core.serializer.Serializer<?> getSerializer()
getSerializer
in class AbstractConnectionFactory
public org.springframework.core.serializer.Deserializer<?> getDeserializer()
getDeserializer
in class AbstractConnectionFactory
public TcpMessageMapper getMapper()
getMapper
in class AbstractConnectionFactory
public void registerListener(TcpListener listener)
AbstractConnectionFactory
registerListener
in class AbstractConnectionFactory
listener
- the TcpListener.public void registerSender(TcpSender sender)
AbstractConnectionFactory
registerSender
in class AbstractConnectionFactory
sender
- The senderpublic void setTaskExecutor(java.util.concurrent.Executor taskExecutor)
setTaskExecutor
in class AbstractConnectionFactory
taskExecutor
- the taskExecutor to setpublic void setDeserializer(org.springframework.core.serializer.Deserializer<?> deserializer)
setDeserializer
in class AbstractConnectionFactory
deserializer
- the deserializer to setpublic void setSerializer(org.springframework.core.serializer.Serializer<?> serializer)
setSerializer
in class AbstractConnectionFactory
serializer
- the serializer to setpublic void setMapper(TcpMessageMapper mapper)
setMapper
in class AbstractConnectionFactory
mapper
- the mapper to set; defaults to a TcpMessageMapper
public boolean isSingleUse()
isSingleUse
in class AbstractConnectionFactory
public void setSingleUse(boolean singleUse)
AbstractConnectionFactory
setSingleUse
in class AbstractConnectionFactory
public void setInterceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain)
setInterceptorFactoryChain
in class AbstractConnectionFactory
public void setLookupHost(boolean lookupHost)
AbstractConnectionFactory
setLookupHost
in class AbstractConnectionFactory
lookupHost
- the lookupHost to setpublic boolean isLookupHost()
isLookupHost
in class AbstractConnectionFactory
public void forceClose(TcpConnection connection)
AbstractClientConnectionFactory
forceClose
in class AbstractClientConnectionFactory
public void start()
start
in interface org.springframework.context.Lifecycle
start
in class AbstractConnectionFactory
public void stop()
AbstractConnectionFactory
stop
in interface org.springframework.context.Lifecycle
stop
in class AbstractConnectionFactory
public int getPhase()
getPhase
in interface org.springframework.context.Phased
getPhase
in class AbstractConnectionFactory
public boolean isAutoStartup()
AbstractConnectionFactory
isAutoStartup
in interface org.springframework.context.SmartLifecycle
isAutoStartup
in class AbstractConnectionFactory
public void stop(java.lang.Runnable callback)
stop
in interface org.springframework.context.SmartLifecycle
stop
in class AbstractConnectionFactory
|
Spring Integration | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |