org.apache.hadoop.hbase.ipc

Class AbstractRpcClient.BlockingRpcChannelImplementation

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractRpcClient.BlockingRpcChannelImplementation

Enclosing class:

AbstractRpcClient

public static class AbstractRpcClient.BlockingRpcChannelImplementation
extends Object

Blocking rpc channel that goes via hbase rpc.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BlockingRpcChannelImplementation(AbstractRpcClient rpcClient, ServerName sn, User ticket, int channelOperationTimeout)

Method Summary

Modifier and Type	Method and Description
Message	callBlockingMethod(Descriptors.MethodDescriptor md, RpcController controller, Message param, Message returnType)

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingRpcChannelImplementation

protected BlockingRpcChannelImplementation(AbstractRpcClient rpcClient,
                                           ServerName sn,
                                           User ticket,
                                           int channelOperationTimeout)

Parameters:

channelOperationTimeout - - the default timeout when no timeout is given

Method Detail

callBlockingMethod

public Message callBlockingMethod(Descriptors.MethodDescriptor md,
                                  RpcController controller,
                                  Message param,
                                  Message returnType)
                           throws ServiceException

Throws:

ServiceException