backtype.storm.testing

Class AckTracker

java.lang.Object

backtype.storm.testing.AckTracker

All Implemented Interfaces:

AckFailDelegate, Serializable

public class AckTracker
extends Object
implements AckFailDelegate

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AckTracker()

Method Summary

Methods

Modifier and Type	Method and 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 Detail

AckTracker

public AckTracker()

Method Detail

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()