activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christian Posta <christian.po...@gmail.com>
Subject Re: Rollback/NACK a single message
Date Thu, 14 Nov 2013 16:04:30 GMT
I'm not too familiar with the NMS libs... but for the Java JMS impl,
you would just throw an exception + combine with the redelivery policy
(eg, disable redelivery?) and that would send back the "poison pill"
or "nack"

On Thu, Nov 14, 2013 at 6:42 AM, jlpedrosa <jlpedrosa@gmail.com> wrote:
> Hi All,We are coding an application to process events in a queue. We are
> using NMS - ActiveMQ 1.6.
> In my mental model the best transactionality comes with:
> IndividualAcknowledge.
> If the proccess goes OK, the message is acknoledge, up to there no problem.
> But message has no rollback/nack method. So I don't really know how to
> perform that patter. Should I open a session per message? (As I want
> multiple threads running at the same time, sequential is not an option).
> somthing like:
> /IMessage m = messageListener.GetMessage();
> ThreadPool.QueueUserWorkItem(new WaitCallback(this.DispatchMessage), m);
> /
> /public void DispatchMessage(Object messageToDispatch)
>         {
>             IMessage m = messageToDispatch as IMessage;
>
>             try
>             {
>                 //Convert to Event.
>                 Event ev = UnMarshallMessage(m); --> not relevant code
>                 //Create an instance of the executor
>                 EventProccessor executor =
> Activator.CreateInstance(ExecutorType) as EventProccessor ;
>                 //Invoke the executor
>                 executor.ProcessEvent(ev);
>                 //commit the message
>                 m.Acknowledge();
>             }
>             catch (Exception ex)
>             {
>                 log.Error("Error processing the message", ex);
>                 m.Rollback() --> does not exist
>             }
> }/
> Thanks in advance for any suggestion,
> Jose Luis
>
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/Rollback-NACK-a-single-message-tp4674444.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.



-- 
Christian Posta
http://www.christianposta.com/blog
twitter: @christianposta

Mime
View raw message