Class ReactorNettyTcpStompSessionManager

java.lang.Object

org.springframework.integration.stomp.AbstractStompSessionManager

org.springframework.integration.stomp.ReactorNettyTcpStompSessionManager

All Implemented Interfaces:

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

public class ReactorNettyTcpStompSessionManager
extends AbstractStompSessionManager

The ReactorNettyTcpStompClient based AbstractStompSessionManager implementation.

Since:

5.0

Author:

Artem Bilan

See Also:

• ReactorNettyTcpStompClient

Field Summary

Fields inherited from class AbstractStompSessionManager

logger, stompClient

Fields inherited from interface SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Constructor	Description
ReactorNettyTcpStompSessionManager(ReactorNettyTcpStompClient reactorNettyTcpStompClient)

Method Summary

Modifier and Type	Method	Description
protected CompletableFuture<StompSession>	doConnect(StompSessionHandler handler)

Methods inherited from class AbstractStompSessionManager

connect, destroy, disconnect, getConnectHeaders, getPhase, getRecoveryInterval, isAutoReceiptEnabled, isAutoStartup, isConnected, isRunning, setApplicationEventPublisher, setAutoReceipt, setAutoStartup, setBeanName, setConnectHeaders, setPhase, setRecoveryInterval, start, stop, toString

Methods inherited from class Object

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

Methods inherited from interface SmartLifecycle

isPauseable, stop

Constructor Details

ReactorNettyTcpStompSessionManager

public ReactorNettyTcpStompSessionManager(ReactorNettyTcpStompClient reactorNettyTcpStompClient)

Method Details

doConnect

protected CompletableFuture<StompSession> doConnect(StompSessionHandler handler)

Specified by:

doConnect in class AbstractStompSessionManager