public class Reactor2TcpStompSessionManager extends AbstractStompSessionManager
Reactor2TcpStompClient
based AbstractStompSessionManager
implementation.Reactor2TcpStompClient
logger, stompClient
Constructor and Description |
---|
Reactor2TcpStompSessionManager(org.springframework.messaging.simp.stomp.Reactor2TcpStompClient reactor2TcpStompClient) |
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 Reactor2TcpStompSessionManager(org.springframework.messaging.simp.stomp.Reactor2TcpStompClient reactor2TcpStompClient)
protected org.springframework.util.concurrent.ListenableFuture<org.springframework.messaging.simp.stomp.StompSession> doConnect(org.springframework.messaging.simp.stomp.StompSessionHandler handler)
doConnect
in class AbstractStompSessionManager