activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From David Sitsky <>
Subject Question about Queue.removeSubscription()
Date Wed, 13 Feb 2008 23:13:41 GMT
I just noticed while looking at Queue.removeSubscription(), that it goes 
through pagedInMessages, and effectively redelivers all messages that 
were locked by the removed subscription.

My question is why is this necessary?  From my understanding in the code 
(which may be flawed), these messages will be present in the pending 
lists of all the other current subscribers, so they should eventually 
dispatch this message since the messages are now unlocked.

I know we call node.incrementRedeliveryCounter() to indicate that the 
message is being redelivered - but it seems to me that we can avoid 
redelivering these messages which seems desirable, since some consumers 
may see the same message twice.


Nuix Pty Ltd
Suite 79, 89 Jones St, Ultimo NSW 2007, Australia    Ph: +61 2 9280 0699
Web:                            Fax: +61 2 9212 6902

View raw message