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 | Class and Description |
---|---|
class |
StompSessionHandlerAdapter
Abstract adapter class for
StompSessionHandler with mostly empty
implementation methods except for StompSessionHandlerAdapter.getPayloadType(org.springframework.messaging.simp.stomp.StompHeaders) which returns String
as the default Object type expected for STOMP ERROR frame payloads. |
Modifier and Type | Method and Description |
---|---|
StompSessionHandler |
DefaultStompSession.getSessionHandler()
Return the configured session handler.
|
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. |
protected ConnectionHandlingStompSession |
StompClientSupport.createSession(StompHeaders connectHeaders,
StompSessionHandler handler)
Factory method for create and configure a new session.
|
Constructor and Description |
---|
DefaultStompSession(StompSessionHandler sessionHandler,
StompHeaders connectHeaders)
Create a new session.
|
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 . |