Interface DistributedRPCInvocations.AsyncIface

All Known Implementing Classes:
DistributedRPCInvocations.AsyncClient
Enclosing class:
DistributedRPCInvocations

public static interface DistributedRPCInvocations.AsyncIface
  • Method Details

    • result

      void result(String id, String result, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
      Throws:
      org.apache.storm.thrift.TException
    • fetchRequest

      void fetchRequest(String functionName, org.apache.storm.thrift.async.AsyncMethodCallback<DRPCRequest> resultHandler) throws org.apache.storm.thrift.TException
      Throws:
      org.apache.storm.thrift.TException
    • failRequest

      void failRequest(String id, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
      Throws:
      org.apache.storm.thrift.TException
    • failRequestV2

      void failRequestV2(String id, DRPCExecutionException e, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException
      Throws:
      org.apache.storm.thrift.TException