Class NettyConnection.CloseFutureListener

  • All Implemented Interfaces:
    io.netty.channel.ChannelFutureListener, io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture>, EventListener
    Enclosing class:
    NettyConnection

    private final class NettyConnection.CloseFutureListener
    extends Object
    implements io.netty.channel.ChannelFutureListener
    Listener for channel close events. If ConnectionConfig.getAutoReconnect() is true, a connection reconnect is attempted on a separate thread.
    • Field Detail

      • reconnecting

        private final AtomicBoolean reconnecting
        Whether this listener is in the process of reconnecting.
    • Constructor Detail

      • CloseFutureListener

        private CloseFutureListener()
    • Method Detail

      • operationComplete

        public void operationComplete​(io.netty.channel.ChannelFuture future)
        Specified by:
        operationComplete in interface io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture>