org.springframework.integration.stomp

Class AbstractStompSessionManager

java.lang.Object

org.springframework.integration.stomp.AbstractStompSessionManager

All Implemented Interfaces:

Aware, BeanNameAware, DisposableBean, InitializingBean, ApplicationEventPublisherAware, StompSessionManager

Direct Known Subclasses:

Reactor2TcpStompSessionManager, WebSocketStompSessionManager

public abstract class AbstractStompSessionManager
extends Object
implements StompSessionManager, ApplicationEventPublisherAware, InitializingBean, 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 afterPropertiesSet().

The destroy() 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

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.commons.logging.Log	logger
protected StompClientSupport	stompClient

Constructor Summary

Constructors

Constructor and Description
AbstractStompSessionManager(StompClientSupport stompClient)

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	connect(StompSessionHandler handler)
void	destroy()
void	disconnect(StompSessionHandler handler)
protected abstract ListenableFuture<StompSession>	doConnect(StompSessionHandler handler)
protected StompHeaders	getConnectHeaders()
boolean	isAutoReceiptEnabled()
boolean	isConnected()
void	setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
void	setAutoReceipt(boolean autoReceipt)
void	setBeanName(String name)
void	setConnectHeaders(StompHeaders connectHeaders)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

logger

protected final org.apache.commons.logging.Log logger

stompClient

protected final StompClientSupport stompClient

Constructor Detail

AbstractStompSessionManager

public AbstractStompSessionManager(StompClientSupport stompClient)

Method Detail

setConnectHeaders

public void setConnectHeaders(StompHeaders connectHeaders)

setAutoReceipt

public void setAutoReceipt(boolean autoReceipt)

isAutoReceiptEnabled

public boolean isAutoReceiptEnabled()

Specified by:

isAutoReceiptEnabled in interface StompSessionManager

isConnected

public boolean isConnected()

Specified by:

isConnected in interface StompSessionManager

setApplicationEventPublisher

public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

Specified by:

setApplicationEventPublisher in interface ApplicationEventPublisherAware

setBeanName

public void setBeanName(String name)

Specified by:

setBeanName in interface BeanNameAware

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface DisposableBean

Throws:

Exception

connect

public void connect(StompSessionHandler handler)

Specified by:

connect in interface StompSessionManager

disconnect

public void disconnect(StompSessionHandler handler)

Specified by:

disconnect in interface StompSessionManager

getConnectHeaders

protected StompHeaders getConnectHeaders()

toString

public String toString()

Overrides:

toString in class Object

doConnect

protected abstract ListenableFuture<StompSession> doConnect(StompSessionHandler handler)