org.springframework.messaging.tcp.reactor

Class ReactorNettyTcpConnection<P>

  • java.lang.Object
    • org.springframework.messaging.tcp.reactor.ReactorNettyTcpConnection<P>
  • Type Parameters:
    P - the type of payload for outbound messages
    All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, TcpConnection<P>


    public class ReactorNettyTcpConnection<P>
    extends java.lang.Object
    implements TcpConnection<P>
    Reactor Netty based implementation of TcpConnection.
    Since:
    5.0
    Author:
    Rossen Stoyanchev
    • Constructor Summary

      Constructors 
      Constructor and Description
      ReactorNettyTcpConnection(reactor.netty.NettyInbound inbound, reactor.netty.NettyOutbound outbound, ReactorNettyCodec<P> codec, reactor.core.publisher.DirectProcessor<java.lang.Void> closeProcessor) 
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method and Description
      void close()
      Close the connection.
      void onReadInactivity(java.lang.Runnable runnable, long inactivityDuration)
      Register a task to invoke after a period of read inactivity.
      void onWriteInactivity(java.lang.Runnable runnable, long inactivityDuration)
      Register a task to invoke after a period of write inactivity.
      ListenableFuture<java.lang.Void> send(Message<P> message)
      Send the given message.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • ReactorNettyTcpConnection

        public ReactorNettyTcpConnection(reactor.netty.NettyInbound inbound,
                                         reactor.netty.NettyOutbound outbound,
                                         ReactorNettyCodec<P> codec,
                                         reactor.core.publisher.DirectProcessor<java.lang.Void> closeProcessor)
    • Method Detail

      • send

        public ListenableFuture<java.lang.Void> send(Message<P> message)
        Description copied from interface: TcpConnection
        Send the given message.
        Specified by:
        send in interface TcpConnection<P>
        Parameters:
        message - the message
        Returns:
        a ListenableFuture that can be used to determine when and if the message was successfully sent
      • onReadInactivity

        public void onReadInactivity(java.lang.Runnable runnable,
                                     long inactivityDuration)
        Description copied from interface: TcpConnection
        Register a task to invoke after a period of read inactivity.
        Specified by:
        onReadInactivity in interface TcpConnection<P>
        Parameters:
        runnable - the task to invoke
        inactivityDuration - the amount of inactive time in milliseconds
      • onWriteInactivity

        public void onWriteInactivity(java.lang.Runnable runnable,
                                      long inactivityDuration)
        Description copied from interface: TcpConnection
        Register a task to invoke after a period of write inactivity.
        Specified by:
        onWriteInactivity in interface TcpConnection<P>
        Parameters:
        runnable - the task to invoke
        inactivityDuration - the amount of inactive time in milliseconds
      • close

        public void close()
        Description copied from interface: TcpConnection
        Close the connection.
        Specified by:
        close in interface java.io.Closeable
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface TcpConnection<P>