Package org.apache.drill.exec.rpc

Class ListeningCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>

java.lang.Object

org.apache.drill.exec.rpc.ListeningCommand<T,C,E,M>

All Implemented Interfaces:

RpcCommand<T,C,E,M>, RpcConnectionHandler<C>

Direct Known Subclasses:

ControlTunnel.CustomMessageSender, ControlTunnel.ReceiverFinished, ControlTunnel.SendFragment, ControlTunnel.SignalFragment

public abstract class ListeningCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>
extends Object
implements RpcCommand<T,C,E,M>

Nested Class Summary

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

RpcConnectionHandler.FailureType

Constructor Summary

Constructors

Constructor	Description
ListeningCommand(RpcOutcomeListener<T> listener)

Method Summary

Modifier and Type	Method	Description
void	connectionAvailable(C connection)
void	connectionFailed(RpcConnectionHandler.FailureType type, Throwable t)
void	connectionSucceeded(C connection)
abstract void	doRpcCall(RpcOutcomeListener<T> outcomeListener, C connection)
RpcOutcomeListener<T>	getOutcomeListener()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.rpc.RpcCommand

getMessage, getRpcType

Constructor Details

ListeningCommand

public ListeningCommand(RpcOutcomeListener<T> listener)

Method Details

doRpcCall

public abstract void doRpcCall(RpcOutcomeListener<T> outcomeListener,
 C connection)

connectionAvailable

public void connectionAvailable(C connection)

Specified by:

connectionAvailable in interface RpcCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>

connectionSucceeded

public void connectionSucceeded(C connection)

Specified by:

connectionSucceeded in interface RpcConnectionHandler<T extends com.google.protobuf.MessageLite>

connectionFailed

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

Specified by:

connectionFailed in interface RpcConnectionHandler<T extends com.google.protobuf.MessageLite>

getOutcomeListener

public RpcOutcomeListener<T> getOutcomeListener()

Specified by:

getOutcomeListener in interface RpcCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>