Package org.apache.storm.testing
Class AckTracker
java.lang.Object
org.apache.storm.testing.AckTracker
- All Implemented Interfaces:
Serializable
,AckFailDelegate
- See Also:
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
void
int
void
-
Constructor Details
-
AckTracker
public AckTracker()
-
-
Method Details
-
ack
- Specified by:
ack
in interfaceAckFailDelegate
-
fail
- Specified by:
fail
in interfaceAckFailDelegate
-
getNumAcks
public int getNumAcks() -
resetNumAcks
public void resetNumAcks()
-