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
The
ReactorNettyTcpStompClient based AbstractStompSessionManager implementation.- Since:
- 5.0
- See Also:
-
ReactorNettyTcpStompClient
-
Field Summary
Fields inherited from class org.springframework.integration.stomp.AbstractStompSessionManager
logger, stompClientFields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
ConstructorsConstructorDescriptionReactorNettyTcpStompSessionManager(org.springframework.messaging.simp.stomp.ReactorNettyTcpStompClient reactorNettyTcpStompClient) -
Method Summary
Modifier and TypeMethodDescriptionprotected CompletableFuture<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, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.springframework.context.SmartLifecycle
stop
-
Constructor Details
-
ReactorNettyTcpStompSessionManager
public ReactorNettyTcpStompSessionManager(org.springframework.messaging.simp.stomp.ReactorNettyTcpStompClient reactorNettyTcpStompClient)
-
-
Method Details
-
doConnect
protected CompletableFuture<org.springframework.messaging.simp.stomp.StompSession> doConnect(org.springframework.messaging.simp.stomp.StompSessionHandler handler) - Specified by:
doConnectin classAbstractStompSessionManager
-