public class DRPCInvocationsClient extends ThriftClient implements DistributedRPCInvocations.Iface
| Modifier and Type | Field and Description |
|---|---|
static org.slf4j.Logger |
LOG |
protocol, retryForever| Constructor and Description |
|---|
DRPCInvocationsClient(Map<String,Object> conf,
String host,
int port) |
| Modifier and Type | Method and Description |
|---|---|
void |
failRequest(String id) |
void |
failRequestV2(String id,
DRPCExecutionException ex) |
DRPCRequest |
fetchRequest(String func) |
DistributedRPCInvocations.Client |
getClient() |
String |
getHost() |
int |
getPort() |
boolean |
isConnected() |
void |
reconnectClient() |
void |
result(String id,
String result) |
close, reconnect, transportpublic String getHost()
public int getPort()
public void reconnectClient()
throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic boolean isConnected()
public void result(String id, String result) throws org.apache.storm.thrift.TException, AuthorizationException
result in interface DistributedRPCInvocations.Ifaceorg.apache.storm.thrift.TExceptionAuthorizationExceptionpublic DRPCRequest fetchRequest(String func) throws org.apache.storm.thrift.TException, AuthorizationException
fetchRequest in interface DistributedRPCInvocations.Ifaceorg.apache.storm.thrift.TExceptionAuthorizationExceptionpublic void failRequest(String id) throws org.apache.storm.thrift.TException, AuthorizationException
failRequest in interface DistributedRPCInvocations.Ifaceorg.apache.storm.thrift.TExceptionAuthorizationExceptionpublic DistributedRPCInvocations.Client getClient()
public void failRequestV2(String id, DRPCExecutionException ex) throws AuthorizationException, org.apache.storm.thrift.TException
failRequestV2 in interface DistributedRPCInvocations.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.