org.apache.drill.exec.rpc.control

Class ControlTunnel.CustomMessageSender

java.lang.Object

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

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

All Implemented Interfaces:

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

Enclosing class:

ControlTunnel

public static class ControlTunnel.CustomMessageSender
extends ListeningCommand<BitControl.CustomMessage,ControlConnection,BitControl.RpcType,BitControl.CustomMessage>

Nested Class Summary

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

RpcConnectionHandler.FailureType

Constructor Summary

Constructors

Constructor and Description
CustomMessageSender(RpcOutcomeListener<BitControl.CustomMessage> listener, BitControl.CustomMessage message, io.netty.buffer.ByteBuf[] dataBodies)

Method Summary

Modifier and Type	Method and 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.ListeningCommand

connectionAvailable, connectionFailed, connectionSucceeded, getOutcomeListener

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomMessageSender

public CustomMessageSender(RpcOutcomeListener<BitControl.CustomMessage> listener,
                           BitControl.CustomMessage message,
                           io.netty.buffer.ByteBuf[] dataBodies)

Method Detail

doRpcCall

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

Specified by:

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

getRpcType

public BitControl.RpcType getRpcType()

getMessage

public BitControl.CustomMessage getMessage()

getDataBodies

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