org.springframework.integration.stomp

Class Reactor2TcpStompSessionManager

java.lang.Object

org.springframework.integration.stomp.AbstractStompSessionManager

org.springframework.integration.stomp.Reactor2TcpStompSessionManager

All Implemented Interfaces:

Aware, BeanNameAware, DisposableBean, ApplicationEventPublisherAware, Lifecycle, Phased, SmartLifecycle, StompSessionManager

public class Reactor2TcpStompSessionManager
extends AbstractStompSessionManager

The Reactor2TcpStompClient based AbstractStompSessionManager implementation.

Since:

4.2

Author:

Artem Bilan

See Also:

Reactor2TcpStompClient

Field Summary

Fields inherited from class org.springframework.integration.stomp.AbstractStompSessionManager

logger, stompClient

Constructor Summary

Constructors

Constructor and Description
Reactor2TcpStompSessionManager(Reactor2TcpStompClient reactor2TcpStompClient)

Method Summary

Modifier and Type	Method and Description
protected ListenableFuture<StompSession>	doConnect(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, stop, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

Reactor2TcpStompSessionManager

public Reactor2TcpStompSessionManager(Reactor2TcpStompClient reactor2TcpStompClient)

Method Detail

doConnect

protected ListenableFuture<StompSession> doConnect(StompSessionHandler handler)

Specified by:

doConnect in class AbstractStompSessionManager