Class ReactorNettyTcpStompSessionManager
java.lang.Object
org.springframework.integration.stomp.AbstractStompSessionManager
org.springframework.integration.stomp.ReactorNettyTcpStompSessionManager
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.context.ApplicationEventPublisherAware,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle,StompSessionManager
public class ReactorNettyTcpStompSessionManager extends AbstractStompSessionManager
The
ReactorNettyTcpStompClient based AbstractStompSessionManager implementation.- Since:
- 5.0
- See Also:
ReactorNettyTcpStompClient
-
Field Summary
Fields inherited from class org.springframework.integration.stomp.AbstractStompSessionManager
logger, stompClient -
Constructor Summary
Constructors Constructor Description ReactorNettyTcpStompSessionManager(org.springframework.messaging.simp.stomp.ReactorNettyTcpStompClient reactorNettyTcpStompClient) -
Method Summary
Modifier and Type Method Description protected org.springframework.util.concurrent.ListenableFuture<org.springframework.messaging.simp.stomp.StompSession>doConnect(org.springframework.messaging.simp.stomp.StompSessionHandler handler)Methods inherited from class org.springframework.integration.stomp.AbstractStompSessionManager
connect, destroy, disconnect, getConnectHeaders, getPhase, getRecoveryInterval, isAutoReceiptEnabled, isAutoStartup, isConnected, isRunning, setApplicationEventPublisher, setAutoReceipt, setAutoStartup, setBeanName, setConnectHeaders, setPhase, setRecoveryInterval, start, stop, toString
-
Constructor Details
-
ReactorNettyTcpStompSessionManager
public ReactorNettyTcpStompSessionManager(org.springframework.messaging.simp.stomp.ReactorNettyTcpStompClient reactorNettyTcpStompClient)
-
-
Method Details
-
doConnect
protected org.springframework.util.concurrent.ListenableFuture<org.springframework.messaging.simp.stomp.StompSession> doConnect(org.springframework.messaging.simp.stomp.StompSessionHandler handler)- Specified by:
doConnectin classAbstractStompSessionManager
-