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

java.lang.Object
org.apache.storm.thrift.AsyncProcessFunction<I,Nimbus.debug_args,Void>
org.apache.storm.generated.Nimbus.AsyncProcessor.debug<I>
Enclosing class:
Nimbus.AsyncProcessor<I extends Nimbus.AsyncIface>

public static class Nimbus.AsyncProcessor.debug<I extends Nimbus.AsyncIface> extends org.apache.storm.thrift.AsyncProcessFunction<I,Nimbus.debug_args,Void>
  • Constructor Details

    • debug

      public debug()
  • Method Details

    • getEmptyArgsInstance

      public Nimbus.debug_args getEmptyArgsInstance()
      Specified by:
      getEmptyArgsInstance in class org.apache.storm.thrift.AsyncProcessFunction<I extends Nimbus.AsyncIface,Nimbus.debug_args,Void>
    • 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>
    • isOneway

      protected boolean isOneway()
      Specified by:
      isOneway 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