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+unsubscribe@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.