|
Spring Integration | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.springframework.integration.ip.tcp.connection.TcpConnectionSupport org.springframework.integration.ip.tcp.connection.TcpNetConnection
public class TcpNetConnection
A TcpConnection that uses and underlying Socket
.
Field Summary |
---|
Fields inherited from class org.springframework.integration.ip.tcp.connection.TcpConnectionSupport |
---|
logger |
Constructor Summary | |
---|---|
TcpNetConnection(java.net.Socket socket,
boolean server,
boolean lookupHost)
Deprecated. Use TcpNetConnection(Socket, boolean, boolean, ApplicationEventPublisher, String)
TODO: Remove in 3.1/4.0 |
|
TcpNetConnection(java.net.Socket socket,
boolean server,
boolean lookupHost,
org.springframework.context.ApplicationEventPublisher applicationEventPublisher,
java.lang.String connectionFactoryName)
Constructs a TcpNetConnection for the socket. |
Method Summary | |
---|---|
void |
close()
Closes this connection. |
java.lang.Object |
getDeserializerStateKey()
|
java.lang.Object |
getPayload()
Uses the deserializer to obtain the message payload from the connection's input stream. |
int |
getPort()
|
protected boolean |
handleReadException(java.lang.Exception e)
|
boolean |
isOpen()
|
void |
run()
If there is no listener, and this connection is not for single use, this method exits. |
void |
send(Message<?> message)
Converts and sends the message. |
Methods inherited from class org.springframework.integration.ip.tcp.connection.TcpConnectionSupport |
---|
afterSend, closeConnection, getConnectionId, getDeserializer, getHostAddress, getHostName, getListener, getMapper, getSender, getSerializer, incrementAndGetConnectionSequence, isServer, isSingleUse, publishConnectionCloseEvent, publishConnectionExceptionEvent, publishConnectionOpenEvent, publishEvent, registerListener, registerSender, setDeserializer, setMapper, setSerializer, setSingleUse |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
@Deprecated public TcpNetConnection(java.net.Socket socket, boolean server, boolean lookupHost)
TcpNetConnection(Socket, boolean, boolean, ApplicationEventPublisher, String)
TODO: Remove in 3.1/4.0
socket
- the socketserver
- if true this connection was created as
a result of an incoming request.lookupHost
- true if hostname lookup should be performed, otherwise the connection will
be identified using the ip address.public TcpNetConnection(java.net.Socket socket, boolean server, boolean lookupHost, org.springframework.context.ApplicationEventPublisher applicationEventPublisher, java.lang.String connectionFactoryName)
socket
- the socketserver
- if true this connection was created as
a result of an incoming request.lookupHost
- true if hostname lookup should be performed, otherwise the connection will
be identified using the ip address.applicationEventPublisher
- the publisher to which OPEN, CLOSE and EXCEPTION events will
be sent; may be null if event publishing is not required.connectionFactoryName
- the name of the connection factory creating this connection; used
during event publishing, may be null, in which case "unknown" will be used.Method Detail |
---|
public void close()
close
in interface TcpConnection
close
in class TcpConnectionSupport
public boolean isOpen()
public void send(Message<?> message) throws java.lang.Exception
TcpConnection
message
- The message
java.lang.Exception
public java.lang.Object getPayload() throws java.lang.Exception
TcpConnection
java.lang.Exception
public int getPort()
public java.lang.Object getDeserializerStateKey()
Deserializer
that
maintains state for this connection. Currently, this would be the InputStream
associated with the connection, but the object should be treated as opaque
and ONLY used as a key.public void run()
Deserializer
and the listener's
TcpListener.onMessage(Message)
method is called. For single use
connections with no listener, the socket is closed after its timeout
expires. If data is received on a single use socket with no listener,
a warning is logged.
protected boolean handleReadException(java.lang.Exception e)
|
Spring Integration | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |