Hi, I have been reading through code and online to find how and where exactly a tuple gets timed out and therefore the spout's fail method is invoked. As I look through the executor.clj class, a RotatingMap is always associated with a Spout. This is where the emitted tuples pending ack are stored.
Every time the RotatingMap's rotate() method is called, it invokes the passed in ExpiryCallback implementation to notify the expired tuple. What I am trying to understand is who calls the rotate() method? I also see a put method in the RotatingMap - I am guessing this is invoked when the Spout emits a new tuple. Is my understanding correct? Thank you very much, Srividhya This email and any files transmitted with it are confidential, proprietary and intended solely for the individual or entity to whom they are addressed. If you have received this email in error please delete it immediately.
