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 and Description
ChannelClosedHandler(C clientConnection, io.netty.channel.Channel channel)

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

ChannelClosedHandler

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

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