public class ReactorNettyTcpStompSessionManager extends AbstractStompSessionManager
ReactorNettyTcpStompClient
based AbstractStompSessionManager
implementation.ReactorNettyTcpStompClient
logger, stompClient
Constructor and Description |
---|
ReactorNettyTcpStompSessionManager(org.springframework.messaging.simp.stomp.ReactorNettyTcpStompClient reactorNettyTcpStompClient) |
Modifier and Type | Method and Description |
---|---|
protected org.springframework.util.concurrent.ListenableFuture<org.springframework.messaging.simp.stomp.StompSession> |
doConnect(org.springframework.messaging.simp.stomp.StompSessionHandler handler) |
connect, destroy, disconnect, getConnectHeaders, getPhase, getRecoveryInterval, isAutoReceiptEnabled, isAutoStartup, isConnected, isRunning, setApplicationEventPublisher, setAutoReceipt, setAutoStartup, setBeanName, setConnectHeaders, setPhase, setRecoveryInterval, start, stop, stop, toString
public ReactorNettyTcpStompSessionManager(org.springframework.messaging.simp.stomp.ReactorNettyTcpStompClient reactorNettyTcpStompClient)
protected org.springframework.util.concurrent.ListenableFuture<org.springframework.messaging.simp.stomp.StompSession> doConnect(org.springframework.messaging.simp.stomp.StompSessionHandler handler)
doConnect
in class AbstractStompSessionManager