public static class AsyncRpcClient.RpcChannelImplementation extends Object implements com.google.protobuf.RpcChannel
Modifier and Type | Field and Description |
---|---|
private int |
channelOperationTimeout |
private InetSocketAddress |
isa |
private AsyncRpcClient |
rpcClient |
private User |
ticket |
Modifier | Constructor and Description |
---|---|
protected |
AsyncRpcClient.RpcChannelImplementation(AsyncRpcClient rpcClient,
ServerName sn,
User ticket,
int channelOperationTimeout) |
Modifier and Type | Method and Description |
---|---|
void |
callMethod(com.google.protobuf.Descriptors.MethodDescriptor md,
com.google.protobuf.RpcController controller,
com.google.protobuf.Message param,
com.google.protobuf.Message returnType,
com.google.protobuf.RpcCallback<com.google.protobuf.Message> done) |
private final InetSocketAddress isa
private final AsyncRpcClient rpcClient
private final User ticket
private final int channelOperationTimeout
protected AsyncRpcClient.RpcChannelImplementation(AsyncRpcClient rpcClient, ServerName sn, User ticket, int channelOperationTimeout)
channelOperationTimeout
- - the default timeout when no timeout is givenpublic void callMethod(com.google.protobuf.Descriptors.MethodDescriptor md, com.google.protobuf.RpcController controller, com.google.protobuf.Message param, com.google.protobuf.Message returnType, com.google.protobuf.RpcCallback<com.google.protobuf.Message> done)
callMethod
in interface com.google.protobuf.RpcChannel
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.