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 -- You received this message because you are subscribed to the Google Groups "elasticsearch" group. To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscr...@googlegroups.com. To view this discussion on the web visit https://groups.google.com/d/msgid/elasticsearch/CAL3_U40og9VKc3m5uZJF_3QdyNdbtz9M0BxHonORNtw%2BDO%3DkUg%40mail.gmail.com. For more options, visit https://groups.google.com/d/optout.
