Package 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	Description
CloseHandler(C connection, io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture> parent)

Method Summary

Modifier and Type	Method	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 Details

CloseHandler

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

Method Details

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