Class Nimbus.AsyncProcessor.debug<I extends Nimbus.AsyncIface>

    • Constructor Detail

      • debug

        public debug()
    • Method Detail

      • getResultHandler

        public org.apache.storm.thrift.async.AsyncMethodCallback<Void> getResultHandler​(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
                                                                                        int seqid)
        Specified by:
        getResultHandler in class org.apache.storm.thrift.AsyncProcessFunction<I extends Nimbus.AsyncIface,​Nimbus.debug_args,​Void>
      • start

        public void start​(I iface,
                          Nimbus.debug_args args,
                          org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                   throws org.apache.storm.thrift.TException
        Specified by:
        start in class org.apache.storm.thrift.AsyncProcessFunction<I extends Nimbus.AsyncIface,​Nimbus.debug_args,​Void>
        Throws:
        org.apache.storm.thrift.TException