Package org.apache.drill.exec.rpc.control

Class ControlTunnel.SyncCustomMessageSender

java.lang.Object

org.apache.drill.exec.rpc.FutureBitCommand<BitControl.CustomMessage,ControlConnection,BitControl.RpcType,BitControl.CustomMessage>

org.apache.drill.exec.rpc.control.ControlTunnel.SyncCustomMessageSender

All Implemented Interfaces:

RpcCommand<BitControl.CustomMessage,ControlConnection,BitControl.RpcType,BitControl.CustomMessage>, RpcConnectionHandler<ControlConnection>

Enclosing class:

ControlTunnel

public static class ControlTunnel.SyncCustomMessageSender
extends FutureBitCommand<BitControl.CustomMessage,ControlConnection,BitControl.RpcType,BitControl.CustomMessage>

Nested Class Summary

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

RpcConnectionHandler.FailureType

Field Summary

Fields inherited from class org.apache.drill.exec.rpc.FutureBitCommand

settableFuture

Constructor Summary

Constructors

Constructor	Description
SyncCustomMessageSender(BitControl.CustomMessage message, io.netty.buffer.ByteBuf[] dataBodies)

Method Summary

Modifier and Type	Method	Description
void	doRpcCall(RpcOutcomeListener<BitControl.CustomMessage> outcomeListener, ControlConnection connection)
io.netty.buffer.ByteBuf[]	getDataBodies()
BitControl.CustomMessage	getMessage()
BitControl.RpcType	getRpcType()

Methods inherited from class org.apache.drill.exec.rpc.FutureBitCommand

connectionAvailable, connectionFailed, connectionSucceeded, getFuture, getOutcomeListener

Methods inherited from class java.lang.Object

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

Constructor Details

SyncCustomMessageSender

public SyncCustomMessageSender(BitControl.CustomMessage message,
 io.netty.buffer.ByteBuf[] dataBodies)

Method Details

doRpcCall

public void doRpcCall(RpcOutcomeListener<BitControl.CustomMessage> outcomeListener,
 ControlConnection connection)

Specified by:

doRpcCall in class FutureBitCommand<BitControl.CustomMessage,ControlConnection,BitControl.RpcType,BitControl.CustomMessage>

getRpcType

public BitControl.RpcType getRpcType()

getMessage

public BitControl.CustomMessage getMessage()

getDataBodies

public io.netty.buffer.ByteBuf[] getDataBodies()