backtype.storm.testing
Class AckFailMapTracker

java.lang.Object
  extended by 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