Class AbstractStompSessionManager

java.lang.Object
org.springframework.integration.stomp.AbstractStompSessionManager
All Implemented Interfaces:
Aware, BeanNameAware, DisposableBean, ApplicationEventPublisherAware, Lifecycle, Phased, SmartLifecycle, StompSessionManager
Direct Known Subclasses:
ReactorNettyTcpStompSessionManager, WebSocketStompSessionManager

public abstract class AbstractStompSessionManager extends Object implements StompSessionManager, ApplicationEventPublisherAware, SmartLifecycle, DisposableBean, BeanNameAware
Base StompSessionManager implementation to manage a single StompSession over its ListenableFuture from the target implementation of this class.

The connection to the StompSession is made during start().

The stop() lifecycle method manages StompSession.disconnect().

The connect(StompSessionHandler) and disconnect(StompSessionHandler) method implementations populate/remove the provided StompSessionHandler to/from an internal AbstractStompSessionManager.CompositeStompSessionHandler, which delegates all operations to the provided StompSessionHandlers. This AbstractStompSessionManager.CompositeStompSessionHandler is used for the StompSession connection.

Since:
4.2
Author:
Artem Bilan, Gary Russell