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

    • Constructor Detail

      • activate

        public activate()
    • 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.activate_args,​Void>
      • start

        public void start​(I iface,
                          Nimbus.activate_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.activate_args,​Void>
        Throws:
        org.apache.storm.thrift.TException