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
-
Method Summary
Modifier and TypeMethodDescriptionvoid
connectionAvailable
(C connection) void
void
connectionSucceeded
(C connection) abstract void
doRpcCall
(RpcOutcomeListener<T> outcomeListener, C connection) 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
-
-
Method Details
-
doRpcCall
-
connectionAvailable
- Specified by:
connectionAvailable
in interfaceRpcCommand<T extends com.google.protobuf.MessageLite,
C extends RemoteConnection, E extends com.google.protobuf.Internal.EnumLite, M extends com.google.protobuf.MessageLite>
-
connectionSucceeded
- Specified by:
connectionSucceeded
in interfaceRpcConnectionHandler<T extends com.google.protobuf.MessageLite>
-
connectionFailed
- Specified by:
connectionFailed
in interfaceRpcConnectionHandler<T extends com.google.protobuf.MessageLite>
-
getOutcomeListener
- Specified by:
getOutcomeListener
in interfaceRpcCommand<T extends com.google.protobuf.MessageLite,
C extends RemoteConnection, E extends com.google.protobuf.Internal.EnumLite, M extends com.google.protobuf.MessageLite>
-