Package org.apache.storm.testing
Class AckFailMapTracker
- java.lang.Object
-
- org.apache.storm.testing.AckFailMapTracker
-
- All Implemented Interfaces:
Serializable
,AckFailDelegate
public class AckFailMapTracker extends Object implements AckFailDelegate
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description AckFailMapTracker()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
ack(Object id)
void
fail(Object id)
boolean
isAcked(Object id)
boolean
isFailed(Object id)
-
-
-
Method Detail
-
isAcked
public boolean isAcked(Object id)
-
isFailed
public boolean isFailed(Object id)
-
ack
public void ack(Object id)
- Specified by:
ack
in interfaceAckFailDelegate
-
fail
public void fail(Object id)
- Specified by:
fail
in interfaceAckFailDelegate
-
-