Hi all, I have the following simple topology:
Spout1 -> Bolt1 1)Spout1 - emits anchored tuples ( collector.emit(new Values(emitWord), msgId); ) - overrides fail method in BaseRichSpout. 2)Bolt1 -delays the processing of the received tuple by invoking a Thread.sleep > Config.TOPOLOGY_MESSAGE_TIMEOUT_SECS. I expected the tuples to timeout and the fail method in Spout1 to be invoked. But, fail method never gets invoked. What am I missing ? -Binita
