Did you turn off autoAck as per the documentation? On Jul 4, 2014 10:59 PM, "Jorge Marizan" <[email protected]> wrote:
> Hi Viktor, Yes I did, > > Let me briefly offer you a better explanation of the situation: > > * The consumer actor receive a single message from a JMS endpoint > (ActiveMQ), there are no new messages arriving until the consumer ack or > report the message. > * Each successfully processed message has to be acknowledged independently, > * Each failed message is rejected sending an exception to the sender() of > the consumer actor > > Using the CLIENT_ACKNOWLEDGE mode on the jms endpoint, when I sent back > an Ack message back to the sender() on the consumer actor, Camel > documentation says the client application code under the hood explicitly > calls the Message.acknowledge() method to acknowledge the message, but > also any other messages in the consumer that have already been completely > processed, and I tried and indeed the behavior was exactly like that. But > for a weird reason all the previous reported messages are being > acknowledged and not retried no matter if an exception was sent back to the > sender() ref on the consumer actor. > > I tried to use INDIVIDUAL_ACKNOWLEDGE mode on the endpoint but based on > Camel documentation it acknowledges only the message on which it is invoked > and apparently there is no way on which I could ack an individual message. > It does not flush acknowledgments for any other completed messages. > > Regards, > Jorge > > On vie 04 jul 2014 02:58:55 AST, √iktor Ҡlang wrote: > >> Hi Jorge, >> >> did you follow these instructions? >> http://doc.akka.io/docs/akka/2.3.4/scala/camel.html# >> Delivery_acknowledgements >> >> >> On Fri, Jul 4, 2014 at 3:20 AM, Jorge Marizan <[email protected] >> <mailto:[email protected]>> wrote: >> >> Hi guys, >> >> Is there a way to notify a message broker from a Camel consumer >> actor using Individual acknowledgement mode? I tried sending back >> an Ack message back to the sender() once the message is received >> but its never ack'ed by the broker (ActiveMQ). >> >> Any help would be greatly appreciated. >> >> -- >> >> Read the docs: >> http://akka.io/docs/ >> Check the FAQ: >> >> http://doc.akka.io/docs/akka/__current/additional/faq.html >> < >> http://doc.akka.io/docs/akka/current/additional/faq.html> >> Search the archives: >> https://groups.google.com/__ >> group/akka-user >> <https://groups.google.com/ >> group/akka-user> >> >> --- You received this message because you are subscribed to the >> Google Groups "Akka User List" group. >> To unsubscribe from this group and stop receiving emails from it, >> send an email to akka-user+unsubscribe@__googlegroups.com >> <mailto:akka-user%[email protected]>. >> To post to this group, send email to [email protected] >> <mailto:[email protected]>. >> Visit this group at http://groups.google.com/__group/akka-user >> <http://groups.google.com/group/akka-user>. >> For more options, visit https://groups.google.com/d/__optout >> <https://groups.google.com/d/optout>. >> >> >> >> >> -- >> Cheers, >> √ >> >> -- >> >>>>>>>>>> Read the docs: http://akka.io/docs/ >> >>>>>>>>>> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user >> --- >> You received this message because you are subscribed to the Google >> Groups "Akka User List" group. >> To unsubscribe from this group and stop receiving emails from it, send >> an email to [email protected] >> <mailto:[email protected]>. >> To post to this group, send email to [email protected] >> <mailto:[email protected]>. >> Visit this group at http://groups.google.com/group/akka-user. >> For more options, visit https://groups.google.com/d/optout. >> > > -- > >> Read the docs: http://akka.io/docs/ >>>>>>>>>>> Check the FAQ: http://doc.akka.io/docs/akka/ >>>>>>>>>>> current/additional/faq.html >>>>>>>>>>> Search the archives: https://groups.google.com/ >>>>>>>>>>> group/akka-user >>>>>>>>>>> >>>>>>>>>> --- You received this message because you are subscribed to the > Google Groups "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to [email protected]. > To post to this group, send email to [email protected]. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
