| Package | Description | 
|---|---|
| org.springframework.messaging.simp.stomp | 
 Generic support for simple messaging protocols (like STOMP). 
 | 
| org.springframework.web.socket.messaging | 
 WebSocket integration for Spring's messaging module. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
ConnectionHandlingStompSession
A  
StompSession that implements
 TcpConnectionHandler in order to send and receive messages. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DefaultStompSession
Default implementation of  
ConnectionHandlingStompSession. | 
| Modifier and Type | Method and Description | 
|---|---|
ListenableFuture<StompSession> | 
ReactorNettyTcpStompClient.connect(StompHeaders connectHeaders,
       StompSessionHandler handler)
An overloaded version of  
ReactorNettyTcpStompClient.connect(StompSessionHandler) that
 accepts headers to use for the STOMP CONNECT frame. | 
ListenableFuture<StompSession> | 
ReactorNettyTcpStompClient.connect(StompSessionHandler handler)
Connect and notify the given  
StompSessionHandler when connected
 on the STOMP level. | 
ListenableFuture<StompSession> | 
DefaultStompSession.getSessionFuture()  | 
ListenableFuture<StompSession> | 
ConnectionHandlingStompSession.getSessionFuture()
Return a future that will complete when the session is ready for use. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
StompSessionHandler.afterConnected(StompSession session,
              StompHeaders connectedHeaders)
Invoked when the session is ready to use, i.e. 
 | 
void | 
StompSessionHandlerAdapter.afterConnected(StompSession session,
              StompHeaders connectedHeaders)
This implementation is empty. 
 | 
void | 
StompSessionHandler.handleException(StompSession session,
               StompCommand command,
               StompHeaders headers,
               byte[] payload,
               Throwable exception)
Handle any exception arising while processing a STOMP frame such as a
 failure to convert the payload or an unhandled exception in the
 application  
StompFrameHandler. | 
void | 
StompSessionHandlerAdapter.handleException(StompSession session,
               StompCommand command,
               StompHeaders headers,
               byte[] payload,
               Throwable exception)
This implementation is empty. 
 | 
void | 
StompSessionHandler.handleTransportError(StompSession session,
                    Throwable exception)
Handle a low level transport error which could be an I/O error or a
 failure to encode or decode a STOMP message. 
 | 
void | 
StompSessionHandlerAdapter.handleTransportError(StompSession session,
                    Throwable exception)
This implementation is empty. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
ListenableFuture<StompSession> | 
WebSocketStompClient.connect(String url,
       StompSessionHandler handler,
       Object... uriVars)
Connect to the given WebSocket URL and notify the given
  
StompSessionHandler
 when connected on the STOMP level after the CONNECTED frame is received. | 
ListenableFuture<StompSession> | 
WebSocketStompClient.connect(String url,
       WebSocketHttpHeaders handshakeHeaders,
       StompHeaders connectHeaders,
       StompSessionHandler handler,
       Object... uriVariables)
An overloaded version of
  
WebSocketStompClient.connect(String, StompSessionHandler, Object...) that also accepts
 WebSocketHttpHeaders to use for the WebSocket handshake and
 StompHeaders for the STOMP CONNECT frame. | 
ListenableFuture<StompSession> | 
WebSocketStompClient.connect(String url,
       WebSocketHttpHeaders handshakeHeaders,
       StompSessionHandler handler,
       Object... uriVariables)
An overloaded version of
  
WebSocketStompClient.connect(String, StompSessionHandler, Object...) that also
 accepts WebSocketHttpHeaders to use for the WebSocket handshake. | 
ListenableFuture<StompSession> | 
WebSocketStompClient.connect(URI url,
       WebSocketHttpHeaders handshakeHeaders,
       StompHeaders connectHeaders,
       StompSessionHandler sessionHandler)
An overloaded version of
  
WebSocketStompClient.connect(String, WebSocketHttpHeaders, StompSessionHandler, Object...)
 that accepts a fully prepared URI. |