Class AckTracker

java.lang.Object
org.apache.storm.testing.AckTracker
All Implemented Interfaces:
Serializable, AckFailDelegate

public class AckTracker extends Object implements AckFailDelegate
See Also:
  • Constructor Details

    • AckTracker

      public AckTracker()
  • Method Details

    • ack

      public void ack(Object id)
      Specified by:
      ack in interface AckFailDelegate
    • fail

      public void fail(Object id)
      Specified by:
      fail in interface AckFailDelegate
    • getNumAcks

      public int getNumAcks()
    • resetNumAcks

      public void resetNumAcks()