Package | Description |
---|---|
org.springframework.messaging.simp.stomp |
Generic support for simple messaging protocols (like STOMP).
|
org.springframework.messaging.tcp |
Contains abstractions and implementation classes for establishing TCP connections via
TcpOperations ,
handling messages via
TcpConnectionHandler ,
as well as sending messages via
TcpConnection . |
org.springframework.messaging.tcp.reactor |
Contains support for TCP messaging based on Reactor.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ConnectionHandlingStompSession
A
StompSession that implements
TcpConnectionHandler in order to send and receive messages. |
interface |
StompTcpConnectionHandler<P>
A
TcpConnectionHandler for use with STOMP connections, exposing
further information about the connection. |
Modifier and Type | Class and Description |
---|---|
class |
DefaultStompSession
Default implementation of
ConnectionHandlingStompSession . |
Modifier and Type | Method and Description |
---|---|
ListenableFuture<Void> |
TcpOperations.connect(TcpConnectionHandler<P> connectionHandler)
Open a new connection.
|
ListenableFuture<Void> |
TcpOperations.connect(TcpConnectionHandler<P> connectionHandler,
ReconnectStrategy reconnectStrategy)
Open a new connection and a strategy for reconnecting if the connection fails.
|
Modifier and Type | Method and Description |
---|---|
ListenableFuture<Void> |
ReactorNettyTcpClient.connect(TcpConnectionHandler<P> handler) |
ListenableFuture<Void> |
ReactorNettyTcpClient.connect(TcpConnectionHandler<P> handler,
ReconnectStrategy strategy) |
protected reactor.netty.tcp.TcpClient |
ReactorNettyTcpClient.extendTcpClient(reactor.netty.tcp.TcpClient tcpClient,
TcpConnectionHandler<P> handler)
Provides an opportunity to initialize the
TcpClient for the given
TcpConnectionHandler which may implement sub-interfaces such as
StompTcpConnectionHandler
that expose further information. |