Hi all,
I'm using BaseRichSpout and to my knowledge, I have to implement the replay
logic to guarantee message processing.
When I see the fail method of BaseRichSpout,public void fail(java.lang.Object
msgId)it just gives me messageId.and of course I set collector in open method.
so I think if I make fail method to do collector.emit(failed tuple), I can
guarantee exactly-once message processing.Is there any way to get a tuple in a
tuple tree by its Id? or do I have to fetch again from some source?
thanks
