Getting tuple by messageId


(Seungjin Lee) #1

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.


(system) #2