Interface DistributedRPCInvocations.AsyncIface

    • Method Detail

      • 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