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 givenUnknownHostException
public 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.BlockingRpcChannel
com.google.protobuf.ServiceException
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.