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?
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 email@example.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.