AFAIK, You have to fetch again by messageID. You can put tuple into your messageID, but I don’t think it’s a good way. If you want to achieve exactly-once messaging semantics, why don’t you use Trident?
On Jun 19, 2014, at 2:16 PM, 이승진 <[email protected]> wrote: > 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 >
