public static class AbstractRpcClient.BlockingRpcChannelImplementation extends Object implements com.google.protobuf.BlockingRpcChannel
| Modifier and Type | Field and Description |
|---|---|
private int |
channelOperationTimeout |
private InetSocketAddress |
isa |
private AbstractRpcClient |
rpcClient |
private User |
ticket |
| Modifier | Constructor and Description |
|---|---|
protected |
AbstractRpcClient.BlockingRpcChannelImplementation(AbstractRpcClient rpcClient,
ServerName sn,
User ticket,
int channelOperationTimeout) |
| Modifier and Type | Method and Description |
|---|---|
com.google.protobuf.Message |
callBlockingMethod(com.google.protobuf.Descriptors.MethodDescriptor md,
com.google.protobuf.RpcController controller,
com.google.protobuf.Message param,
com.google.protobuf.Message returnType) |
private final InetSocketAddress isa
private final AbstractRpcClient rpcClient
private final User ticket
private final int channelOperationTimeout
protected AbstractRpcClient.BlockingRpcChannelImplementation(AbstractRpcClient rpcClient, ServerName sn, User ticket, int channelOperationTimeout) throws UnknownHostException
channelOperationTimeout - - the default timeout when no timeout is givenUnknownHostExceptionpublic com.google.protobuf.Message callBlockingMethod(com.google.protobuf.Descriptors.MethodDescriptor md,
com.google.protobuf.RpcController controller,
com.google.protobuf.Message param,
com.google.protobuf.Message returnType)
throws com.google.protobuf.ServiceException
callBlockingMethod in interface com.google.protobuf.BlockingRpcChannelcom.google.protobuf.ServiceExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.