Class NettyIoAcceptor

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel, org.apache.sshd.common.Closeable, org.apache.sshd.common.io.IoAcceptor, org.apache.sshd.common.io.IoService, org.apache.sshd.common.io.IoServiceEventListenerManager

    public class NettyIoAcceptor
    extends NettyIoService
    implements org.apache.sshd.common.io.IoAcceptor
    The Netty based IoAcceptor implementation.
    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable

        org.apache.sshd.common.util.closeable.AbstractCloseable.State
    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected io.netty.bootstrap.ServerBootstrap bootstrap  
      protected java.util.Map<java.net.SocketAddress,​io.netty.channel.Channel> boundAddresses  
      private static io.netty.handler.logging.LoggingHandler LOGGING_TRACE  
      • Fields inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable

        closeFuture, futureLock, state
      • Fields inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean

        log
      • Fields inherited from interface org.apache.sshd.common.io.IoService

        DEFAULT_REUSE_ADDRESS
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void bind​(java.net.SocketAddress address)  
      void bind​(java.util.Collection<? extends java.net.SocketAddress> addresses)  
      protected io.netty.channel.Channel bindInternal​(java.net.SocketAddress address)  
      protected void closeChannel​(io.netty.channel.Channel channel)  
      protected org.apache.sshd.common.future.CloseFuture doCloseGracefully()  
      protected void doCloseImmediately()  
      java.util.Set<java.net.SocketAddress> getBoundAddresses()  
      void unbind()  
      void unbind​(java.net.SocketAddress address)  
      void unbind​(java.util.Collection<? extends java.net.SocketAddress> addresses)  
      • Methods inherited from class org.apache.sshd.common.util.closeable.AbstractCloseable

        addCloseFutureListener, builder, close, getFutureLock, isClosed, isClosing, preClose, removeCloseFutureListener
      • Methods inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean

        debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
      • Methods inherited from interface org.apache.sshd.common.Closeable

        addCloseFutureListener, close, close, isClosed, isClosing, isOpen, removeCloseFutureListener
      • Methods inherited from interface org.apache.sshd.common.io.IoService

        getManagedSessions
      • Methods inherited from interface org.apache.sshd.common.io.IoServiceEventListenerManager

        getIoServiceEventListener, setIoServiceEventListener
    • Field Detail

      • LOGGING_TRACE

        private static final io.netty.handler.logging.LoggingHandler LOGGING_TRACE
      • bootstrap

        protected final io.netty.bootstrap.ServerBootstrap bootstrap
      • boundAddresses

        protected final java.util.Map<java.net.SocketAddress,​io.netty.channel.Channel> boundAddresses
    • Constructor Detail

      • NettyIoAcceptor

        public NettyIoAcceptor​(NettyIoServiceFactory factory,
                               org.apache.sshd.common.io.IoHandler handler)
    • Method Detail

      • bind

        public void bind​(java.util.Collection<? extends java.net.SocketAddress> addresses)
                  throws java.io.IOException
        Specified by:
        bind in interface org.apache.sshd.common.io.IoAcceptor
        Throws:
        java.io.IOException
      • bind

        public void bind​(java.net.SocketAddress address)
                  throws java.io.IOException
        Specified by:
        bind in interface org.apache.sshd.common.io.IoAcceptor
        Throws:
        java.io.IOException
      • bindInternal

        protected io.netty.channel.Channel bindInternal​(java.net.SocketAddress address)
                                                 throws java.io.IOException
        Throws:
        java.io.IOException
      • closeChannel

        protected void closeChannel​(io.netty.channel.Channel channel)
      • unbind

        public void unbind​(java.util.Collection<? extends java.net.SocketAddress> addresses)
        Specified by:
        unbind in interface org.apache.sshd.common.io.IoAcceptor
      • unbind

        public void unbind​(java.net.SocketAddress address)
        Specified by:
        unbind in interface org.apache.sshd.common.io.IoAcceptor
      • unbind

        public void unbind()
        Specified by:
        unbind in interface org.apache.sshd.common.io.IoAcceptor
      • getBoundAddresses

        public java.util.Set<java.net.SocketAddress> getBoundAddresses()
        Specified by:
        getBoundAddresses in interface org.apache.sshd.common.io.IoAcceptor
      • doCloseGracefully

        protected org.apache.sshd.common.future.CloseFuture doCloseGracefully()
        Overrides:
        doCloseGracefully in class org.apache.sshd.common.util.closeable.AbstractCloseable
      • doCloseImmediately

        protected void doCloseImmediately()
        Overrides:
        doCloseImmediately in class org.apache.sshd.common.util.closeable.AbstractCloseable