public abstract class TcpConnectionInterceptorSupport extends TcpConnectionSupport implements TcpConnectionInterceptor
TcpConnection
.logger
Constructor and Description |
---|
TcpConnectionInterceptorSupport() |
TcpConnectionInterceptorSupport(ApplicationEventPublisher applicationEventPublisher) |
Modifier and Type | Method and Description |
---|---|
void |
addNewConnection(TcpConnection connection)
When we are using sockets owned by a
TcpListener , this
method is called each time a new connection is made. |
void |
close()
Closes this connection.
|
String |
getConnectionFactoryName() |
String |
getConnectionId() |
Deserializer<?> |
getDeserializer() |
Object |
getDeserializerStateKey() |
String |
getHostAddress() |
String |
getHostName() |
TcpListener |
getListener() |
Object |
getPayload()
Uses the deserializer to obtain the message payload
from the connection's input stream.
|
int |
getPort() |
TcpSender |
getSender() |
Serializer<?> |
getSerializer() |
SocketInfo |
getSocketInfo()
Provides getters for
Socket properties. |
SSLSession |
getSslSession() |
TcpConnectionSupport |
getTheConnection()
Returns the underlying connection (or next interceptor)
|
protected boolean |
hasRealSender() |
long |
incrementAndGetConnectionSequence() |
boolean |
isOpen() |
boolean |
isServer() |
boolean |
onMessage(Message<?> message)
Called by a TCPConnection when a new message arrives.
|
void |
registerListener(TcpListener listener)
Set the listener that will receive incoming Messages.
|
void |
registerSender(TcpSender sender)
Registers a sender.
|
void |
removeDeadConnection(TcpConnection connection)
When we are using sockets owned by a
TcpListener , this
method is called each time a connection is closed. |
void |
run() |
void |
send(Message<?> message)
Converts and sends the message.
|
void |
setDeserializer(Deserializer<?> deserializer) |
void |
setMapper(TcpMessageMapper mapper) |
void |
setSerializer(Serializer<?> serializer) |
void |
setTheConnection(TcpConnectionSupport theConnection)
Sets the underlying connection (or next interceptor)
|
closeConnection, enableManualListenerRegistration, getMapper, isNoReadErrorOnClose, publishConnectionCloseEvent, publishConnectionExceptionEvent, publishConnectionOpenEvent, publishEvent, sendExceptionToListener, setNoReadErrorOnClose, toString
public TcpConnectionInterceptorSupport()
public TcpConnectionInterceptorSupport(ApplicationEventPublisher applicationEventPublisher)
public void close()
TcpConnectionSupport
close
in interface TcpConnection
close
in class TcpConnectionSupport
public boolean isOpen()
isOpen
in interface TcpConnection
public Object getPayload() throws Exception
TcpConnection
getPayload
in interface TcpConnection
Exception
- Any Exception.public String getHostName()
getHostName
in interface TcpConnection
getHostName
in class TcpConnectionSupport
public String getHostAddress()
getHostAddress
in interface TcpConnection
getHostAddress
in class TcpConnectionSupport
public int getPort()
getPort
in interface TcpConnection
public Object getDeserializerStateKey()
getDeserializerStateKey
in interface TcpConnection
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 registerListener(TcpListener listener)
TcpConnectionSupport
registerListener
in class TcpConnectionSupport
listener
- The listener.public void registerSender(TcpSender sender)
TcpConnectionSupport
registerSender
in class TcpConnectionSupport
sender
- the sender.public String getConnectionId()
getConnectionId
in interface TcpConnection
getConnectionId
in class TcpConnectionSupport
public SocketInfo getSocketInfo()
TcpConnection
Socket
properties.getSocketInfo
in interface TcpConnection
getSocketInfo
in class TcpConnectionSupport
public String getConnectionFactoryName()
getConnectionFactoryName
in class TcpConnectionSupport
public void setMapper(TcpMessageMapper mapper)
setMapper
in class TcpConnectionSupport
mapper
- the mapper to setpublic Deserializer<?> getDeserializer()
getDeserializer
in interface TcpConnection
getDeserializer
in class TcpConnectionSupport
public void setDeserializer(Deserializer<?> deserializer)
setDeserializer
in class TcpConnectionSupport
deserializer
- the deserializer to setpublic Serializer<?> getSerializer()
getSerializer
in interface TcpConnection
getSerializer
in class TcpConnectionSupport
public void setSerializer(Serializer<?> serializer)
setSerializer
in class TcpConnectionSupport
serializer
- the serializer to setpublic boolean isServer()
isServer
in interface TcpConnection
isServer
in class TcpConnectionSupport
public SSLSession getSslSession()
getSslSession
in interface TcpConnection
SSLSession
associated with this connection, if SSL is in use,
null otherwise.public boolean onMessage(Message<?> message)
TcpListener
onMessage
in interface TcpListener
message
- The message.public void send(Message<?> message) throws Exception
TcpConnection
send
in interface TcpConnection
message
- The message,Exception
- Any Exception.public TcpConnectionSupport getTheConnection()
public void setTheConnection(TcpConnectionSupport theConnection)
theConnection
- the connectionpublic TcpListener getListener()
getListener
in interface TcpConnection
getListener
in class TcpConnectionSupport
public void addNewConnection(TcpConnection connection)
TcpSender
TcpListener
, this
method is called each time a new connection is made.addNewConnection
in interface TcpSender
connection
- The connection.public void removeDeadConnection(TcpConnection connection)
TcpSender
TcpListener
, this
method is called each time a connection is closed.removeDeadConnection
in interface TcpSender
connection
- The connection.public long incrementAndGetConnectionSequence()
incrementAndGetConnectionSequence
in interface TcpConnection
incrementAndGetConnectionSequence
in class TcpConnectionSupport
public TcpSender getSender()
getSender
in class TcpConnectionSupport
protected boolean hasRealSender()