|
Spring Integration | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.springframework.integration.ip.tcp.connection.AbstractTcpConnection
public abstract class AbstractTcpConnection
Base class for TcpConnections. TcpConnections are established by client connection factories (outgoing) or server connection factories (incoming).
Field Summary | |
---|---|
protected org.apache.commons.logging.Log |
logger
|
Constructor Summary | |
---|---|
AbstractTcpConnection(java.net.Socket socket,
boolean server,
boolean lookupHost)
|
Method Summary | |
---|---|
void |
afterSend(Message<?> message)
|
void |
close()
Closes this connection. |
protected void |
closeConnection(boolean isException)
If we have been intercepted, propagate the close from the outermost interceptor; otherwise, just call close(). |
java.lang.String |
getConnectionId()
|
org.springframework.core.serializer.Deserializer<?> |
getDeserializer()
|
java.lang.String |
getHostAddress()
|
java.lang.String |
getHostName()
|
TcpListener |
getListener()
|
TcpMessageMapper |
getMapper()
|
TcpSender |
getSender()
|
org.springframework.core.serializer.Serializer<?> |
getSerializer()
|
long |
incrementAndGetConnectionSequence()
|
protected boolean |
isNoReadErrorOnClose()
|
boolean |
isServer()
|
boolean |
isSingleUse()
|
void |
registerListener(TcpListener listener)
Sets the listener that will receive incoming Messages. |
void |
registerSender(TcpSender sender)
Registers a sender. |
void |
setDeserializer(org.springframework.core.serializer.Deserializer<?> deserializer)
|
void |
setMapper(TcpMessageMapper mapper)
|
protected void |
setNoReadErrorOnClose(boolean noReadErrorOnClose)
|
void |
setSerializer(org.springframework.core.serializer.Serializer<?> serializer)
|
void |
setSingleUse(boolean singleUse)
When true, the socket is used once and discarded. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.springframework.integration.ip.tcp.connection.TcpConnection |
---|
getPayload, getPort, isOpen, send |
Methods inherited from interface java.lang.Runnable |
---|
run |
Field Detail |
---|
protected final org.apache.commons.logging.Log logger
Constructor Detail |
---|
public AbstractTcpConnection(java.net.Socket socket, boolean server, boolean lookupHost)
Method Detail |
---|
public void afterSend(Message<?> message) throws java.lang.Exception
java.lang.Exception
public void close()
close
in interface TcpConnection
protected void closeConnection(boolean isException)
public TcpMessageMapper getMapper()
public void setMapper(TcpMessageMapper mapper)
setMapper
in interface TcpConnection
mapper
- the mapper to setpublic org.springframework.core.serializer.Deserializer<?> getDeserializer()
getDeserializer
in interface TcpConnection
public void setDeserializer(org.springframework.core.serializer.Deserializer<?> deserializer)
setDeserializer
in interface TcpConnection
deserializer
- the deserializer to setpublic org.springframework.core.serializer.Serializer<?> getSerializer()
getSerializer
in interface TcpConnection
public void setSerializer(org.springframework.core.serializer.Serializer<?> serializer)
setSerializer
in interface TcpConnection
serializer
- the serializer to setpublic void registerListener(TcpListener listener)
TcpConnection
registerListener
in interface TcpConnection
listener
- the listener to setpublic void registerSender(TcpSender sender)
TcpConnection
registerSender
in interface TcpConnection
sender
- the sender to setpublic TcpListener getListener()
getListener
in interface TcpConnection
public TcpSender getSender()
public void setSingleUse(boolean singleUse)
TcpConnection
setSingleUse
in interface TcpConnection
singleUse
- true if this socket is to used once and
discarded.public boolean isSingleUse()
isSingleUse
in interface TcpConnection
public boolean isServer()
isServer
in interface TcpConnection
public long incrementAndGetConnectionSequence()
incrementAndGetConnectionSequence
in interface TcpConnection
public java.lang.String getHostAddress()
getHostAddress
in interface TcpConnection
public java.lang.String getHostName()
getHostName
in interface TcpConnection
public java.lang.String getConnectionId()
getConnectionId
in interface TcpConnection
protected boolean isNoReadErrorOnClose()
protected void setNoReadErrorOnClose(boolean noReadErrorOnClose)
|
Spring Integration | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |