Package org.apache.storm.testing

Class AckTracker

java.lang.Object

org.apache.storm.testing.AckTracker

All Implemented Interfaces:

Serializable, AckFailDelegate

public class AckTracker
extends Object
implements AckFailDelegate

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
AckTracker()

Method Summary

Modifier and Type	Method	Description
void	ack(Object id)
void	fail(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 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()