backtype.storm.testing
Class AckTracker

java.lang.Object
  backtype.storm.testing.AckTracker

All Implemented Interfaces:

AckFailDelegate, java.io.Serializable

public class AckTracker
extends java.lang.Object
implements AckFailDelegate

See Also:

Serialized Form

Constructor Summary

AckTracker()

Method Summary

void	ack(java.lang.Object id)
void	fail(java.lang.Object id)
int	getNumAcks()
void	resetNumAcks()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AckTracker

public AckTracker()

Method Detail

ack

public void ack(java.lang.Object id)

Specified by:

ack in interface AckFailDelegate

fail

public void fail(java.lang.Object id)

Specified by:

fail in interface AckFailDelegate

getNumAcks

public int getNumAcks()

resetNumAcks

public void resetNumAcks()