org.apache.hadoop.hbase.ipc

Class AsyncRpcClient.RpcChannelImplementation

java.lang.Object

org.apache.hadoop.hbase.ipc.AsyncRpcClient.RpcChannelImplementation

Enclosing class:

AsyncRpcClient

public static class AsyncRpcClient.RpcChannelImplementation
extends Object

Blocking rpc channel that goes via hbase rpc.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RpcChannelImplementation(AsyncRpcClient rpcClient, ServerName sn, User ticket, int channelOperationTimeout)

Method Summary

Modifier and Type	Method and Description
void	callMethod(Descriptors.MethodDescriptor md, RpcController controller, Message param, Message returnType, <any> done)

Methods inherited from class java.lang.Object

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

Constructor Detail

RpcChannelImplementation

protected RpcChannelImplementation(AsyncRpcClient rpcClient,
                                   ServerName sn,
                                   User ticket,
                                   int channelOperationTimeout)

Parameters:

channelOperationTimeout - - the default timeout when no timeout is given

Method Detail

callMethod

public void callMethod(Descriptors.MethodDescriptor md,
                       RpcController controller,
                       Message param,
                       Message returnType,
                       <any> done)