Delete all items from queue with same Message Groups id

[Umut Kocasaraç <uk...@gmail.com>]

Hi everyone, I am adding some item on active mq queue with message group id
(JMSXGroupID). When someting goes wrong on queue consumer i would like to
delete all items with same message group id.

For example i have one queue and i have added 5 items to it.

Message id =1
*Message Group id = 1 Message=Test Message 1 on group1 *
Message id =2
*Message Group id = 1 Message=Test Message 2 on group1 *
Message id =3
*Message Group id = 2 Message=Test Message 1 on group2*
Message id =4
*Message Group id = 2 Message=Test Message 2 on group2*
Message id =5
*Message Group id = 1 Message=Test Message 3 on group1 *

When i consume first message i get some exception. So i would like to
delete all message which have same group id. In this case i would like to
delete Message2 and Message5 without send them to consumers. Is there any
way to accomplished this. Thanks,

Re: Delete all items from queue with same Message Groups id

[Timothy Bish <ta...@gmail.com>]

On Tue, 2012-08-07 at 11:32 +0300, Umut Kocasaraç wrote: 
> Hi everyone, I am adding some item on active mq queue with message group id
> (JMSXGroupID). When someting goes wrong on queue consumer i would like to
> delete all items with same message group id.
> 
> For example i have one queue and i have added 5 items to it.
> 
> Message id =1
> *Message Group id = 1 Message=Test Message 1 on group1 *
> Message id =2
> *Message Group id = 1 Message=Test Message 2 on group1 *
> Message id =3
> *Message Group id = 2 Message=Test Message 1 on group2*
> Message id =4
> *Message Group id = 2 Message=Test Message 2 on group2*
> Message id =5
> *Message Group id = 1 Message=Test Message 3 on group1 *
> 
> When i consume first message i get some exception. So i would like to
> delete all message which have same group id. In this case i would like to
> delete Message2 and Message5 without send them to consumers. Is there any
> way to accomplished this. Thanks,

Have a look at the JMX management options for ActiveMQ.  

http://activemq.apache.org/jmx-support.html 
http://www.consulting-notes.com/2010/08/monitoring-and-managing-activemq-with.html


-- 
Tim Bish
Sr Software Engineer | FuseSource Corp
tim.bish@fusesource.com | www.fusesource.com
skype: tabish121 | twitter: @tabish121
blog: http://timbish.blogspot.com/