backtype.storm.testing

Class AckFailMapTracker

java.lang.Object

backtype.storm.testing.AckFailMapTracker

All Implemented Interfaces:

AckFailDelegate, Serializable

public class AckFailMapTracker
extends Object
implements AckFailDelegate

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AckFailMapTracker()

Method Summary

Methods

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

isFailed

public boolean isFailed(Object id)

ack

public void ack(Object id)

Specified by:

ack in interface AckFailDelegate

fail

public void fail(Object id)

Specified by:

fail in interface AckFailDelegate