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
See Also:
ReactorNettyTcpStompClient
  • Constructor Details

    • ReactorNettyTcpStompSessionManager

      public ReactorNettyTcpStompSessionManager​(org.springframework.messaging.simp.stomp.ReactorNettyTcpStompClient reactorNettyTcpStompClient)
  • Method Details

    • 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