Hi, I am trying to run a test on JMS-Activemq with storm. I have one spout reading from Activemq and 2 bolts.
I configured everything needed for guarantee delivery including: · ack/fail. · fail will remove pending messages and ack will send ack on those messages. · Recovery task which will call session.recover I try to kill workers and see if the messages are resent. I see the messages enter the fail code correctly and recovery is called, but the activemq will resend some of the messages but not all (in multiple failures it will resend one message) Any ideas why? I am out of ideas. Thanks, Michal
