org.apache.drill.exec.rpc

Class ReconnectingConnection.CloseHandler

java.lang.Object

org.apache.drill.exec.rpc.ReconnectingConnection.CloseHandler

All Implemented Interfaces:

io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture>, EventListener

Enclosing class:

ReconnectingConnection<C extends ClientConnection,HS extends com.google.protobuf.MessageLite>

protected class ReconnectingConnection.CloseHandler
extends Object
implements io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture>

Listens for connection closes and clears connection holder.

Constructor Summary

Constructors

Constructor and Description
CloseHandler(C connection, io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture> parent)

Method Summary

Modifier and Type	Method and Description
void	operationComplete(io.netty.channel.ChannelFuture future)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CloseHandler

public CloseHandler(C connection,
                    io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture> parent)

Method Detail

operationComplete

public void operationComplete(io.netty.channel.ChannelFuture future)
                       throws Exception

Specified by:

operationComplete in interface io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture>

Throws:

Exception