Package org.apache.drill.exec.rpc

Class RpcBus.ChannelClosedHandler

java.lang.Object

org.apache.drill.exec.rpc.RpcBus.ChannelClosedHandler

All Implemented Interfaces:

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

Enclosing class:

RpcBus<T extends com.google.protobuf.Internal.EnumLite,C extends RemoteConnection>

public class RpcBus.ChannelClosedHandler
extends Object
implements io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture>

Constructor Summary

Constructors

Constructor	Description
ChannelClosedHandler(C clientConnection, io.netty.channel.Channel channel)

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

ChannelClosedHandler

public ChannelClosedHandler(C clientConnection,
 io.netty.channel.Channel channel)

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