Class ReactorListener


  • public final class ReactorListener
    extends java.lang.Object
    NioListener provides a way to react on incoming messages.
    • Field Detail

      • log

        private static org.slf4j.Logger log
      • channel

        private final java.nio.channels.ServerSocketChannel channel
      • reactor

        private final Reactor reactor
      • selector

        private final java.nio.channels.Selector selector
    • Constructor Detail

      • ReactorListener

        public ReactorListener​(Reactor reactor,
                               java.net.InetSocketAddress address,
                               java.nio.channels.Selector selector,
                               ReactorListener.EventListener eventListener)
                        throws java.io.IOException
        Throws:
        java.io.IOException
    • Method Detail

      • setupChannel

        private java.nio.channels.ServerSocketChannel setupChannel​(java.net.InetSocketAddress address)
                                                            throws java.io.IOException
        Throws:
        java.io.IOException
      • getPort

        public int getPort()
      • close

        public java.util.concurrent.Future<java.lang.Void> close()