private class StompBrokerRelayMessageHandler.SystemStompConnectionHandler extends StompBrokerRelayMessageHandler.StompConnectionHandler
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
SESSION_ID |
Constructor and Description |
---|
SystemStompConnectionHandler(StompHeaderAccessor connectHeaders) |
Modifier and Type | Method and Description |
---|---|
void |
afterConnectionClosed()
Invoked after the connection is closed.
|
protected void |
afterStompConnected(StompHeaderAccessor connectedHeaders)
Invoked after the STOMP CONNECTED frame is received.
|
ListenableFuture<java.lang.Void> |
forward(Message<?> message) |
protected void |
handleTcpConnectionFailure(java.lang.String errorMessage,
java.lang.Throwable t)
Invoked when any TCP connectivity issue is detected, i.e.
|
afterConnected, afterConnectFailure, clearConnection, getSessionId, handleMessage, sendMessageToClient, toString
public static final java.lang.String SESSION_ID
public SystemStompConnectionHandler(StompHeaderAccessor connectHeaders)
protected void afterStompConnected(StompHeaderAccessor connectedHeaders)
StompBrokerRelayMessageHandler.StompConnectionHandler
afterStompConnected
in class StompBrokerRelayMessageHandler.StompConnectionHandler
protected void handleTcpConnectionFailure(java.lang.String errorMessage, java.lang.Throwable t)
StompBrokerRelayMessageHandler.StompConnectionHandler
handleTcpConnectionFailure
in class StompBrokerRelayMessageHandler.StompConnectionHandler
public void afterConnectionClosed()
TcpConnectionHandler
afterConnectionClosed
in interface TcpConnectionHandler<byte[]>
afterConnectionClosed
in class StompBrokerRelayMessageHandler.StompConnectionHandler
public ListenableFuture<java.lang.Void> forward(Message<?> message)
forward
in class StompBrokerRelayMessageHandler.StompConnectionHandler