Package org.apache.storm.testing
Class AckFailMapTracker
java.lang.Object
org.apache.storm.testing.AckFailMapTracker
- All Implemented Interfaces:
Serializable
,AckFailDelegate
- See Also:
-
Constructor Summary
-
Method Summary
-
Constructor Details
-
AckFailMapTracker
public AckFailMapTracker()
-
-
Method Details
-
isAcked
-
isFailed
-
ack
- Specified by:
ack
in interfaceAckFailDelegate
-
fail
- Specified by:
fail
in interfaceAckFailDelegate
-