backtype.storm.testing
Class AckFailMapTracker

java.lang.Object
  backtype.storm.testing.AckFailMapTracker

All Implemented Interfaces:

AckFailDelegate, java.io.Serializable

public class AckFailMapTracker
extends java.lang.Object
implements AckFailDelegate

See Also:

Serialized Form

Constructor Summary

AckFailMapTracker()

Method Summary

void	ack(java.lang.Object id)
void	fail(java.lang.Object id)
boolean	isAcked(java.lang.Object id)
boolean	isFailed(java.lang.Object id)

Methods inherited from class java.lang.Object

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

Constructor Detail

AckFailMapTracker

public AckFailMapTracker()

Method Detail

isAcked

public boolean isAcked(java.lang.Object id)

isFailed

public boolean isFailed(java.lang.Object id)

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