org.apache.drill.exec.rpc

Class ReconnectingConnection.ConnectionListeningFuture<R extends com.google.protobuf.MessageLite,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>

java.lang.Object

org.apache.drill.shaded.guava.com.google.common.util.concurrent.internal.InternalFutureFailureAccess

org.apache.drill.shaded.guava.com.google.common.util.concurrent.AbstractFuture<C>

org.apache.drill.exec.rpc.ReconnectingConnection.ConnectionListeningFuture<R,E,M>

All Implemented Interfaces:

Future<C>, RpcConnectionHandler<C>, org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture<C>

Enclosing class:

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

public class ReconnectingConnection.ConnectionListeningFuture<R extends com.google.protobuf.MessageLite,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>
extends org.apache.drill.shaded.guava.com.google.common.util.concurrent.AbstractFuture<C>
implements RpcConnectionHandler<C>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.exec.rpc.RpcConnectionHandler

RpcConnectionHandler.FailureType

Constructor Summary

Constructors

Constructor and Description
ConnectionListeningFuture(RpcCommand<R,C,E,M> cmd)

Method Summary

Modifier and Type	Method and Description
void	connectionFailed(RpcConnectionHandler.FailureType type, Throwable t)
void	connectionSucceeded(C incoming)
void	waitAndRun() Called by

Methods inherited from class org.apache.drill.shaded.guava.com.google.common.util.concurrent.AbstractFuture

addListener, afterDone, cancel, get, get, interruptTask, isCancelled, isDone, pendingToString, set, setException, setFuture, toString, tryInternalFastPathGetFailure, wasInterrupted

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionListeningFuture

public ConnectionListeningFuture(RpcCommand<R,C,E,M> cmd)

Method Detail

waitAndRun

public void waitAndRun()

Called by

connectionFailed

public void connectionFailed(RpcConnectionHandler.FailureType type,
                             Throwable t)

Specified by:

connectionFailed in interface RpcConnectionHandler<C extends ClientConnection>

connectionSucceeded

public void connectionSucceeded(C incoming)

Specified by:

connectionSucceeded in interface RpcConnectionHandler<C extends ClientConnection>