org.springframework.integration.stomp

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

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 org.springframework.integration.stomp.AbstractStompSessionManager

logger, stompClient

Constructor Summary

Constructors

Constructor and Description
ReactorNettyTcpStompSessionManager(org.springframework.messaging.simp.stomp.ReactorNettyTcpStompClient reactorNettyTcpStompClient)

Method Summary

Modifier and Type	Method and Description
protected org.springframework.util.concurrent.ListenableFuture<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, stop, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactorNettyTcpStompSessionManager

public ReactorNettyTcpStompSessionManager(org.springframework.messaging.simp.stomp.ReactorNettyTcpStompClient reactorNettyTcpStompClient)

Method Detail

doConnect

protected org.springframework.util.concurrent.ListenableFuture<org.springframework.messaging.simp.stomp.StompSession> doConnect(org.springframework.messaging.simp.stomp.StompSessionHandler handler)

Specified by:

doConnect in class AbstractStompSessionManager