Hello, I've checkout the source from 5.2.0 tag : http://svn.apache.org/repos/asf/activemq/tags/activemq-5.2.0/ With this tags there is no PersistenceAdapter.removeQueueMessageStore(ActiveMQQueue destination) and PersistenceAdapter.removeTopicMessageStore(ActiveMQTopic destination). That's why I didn't see it...
I'm using AMQ store and I implemented a patch for this tag currently which implements exactly the same methods, but if the implementation is already done for the AMQ store on the trunk I'll be happy to get this correction on my 5.2.0 tag. What's the policy about 5.2.0 corrections ? I see there is no branches for 5.2.0 release (may I false ?). Are these kind of corrections delivered in some patchs from the trunk for example ? Do I need to work with the ActiveMQ trunk ? Thanks Andreas Gies wrote: > > Hi there, > > The PersistenceAdapter interface specifies methods > > /** > * Cleanup method to remove any state associated with the given > destination. > * This method does not stop the message store (it might not be > cached). > * @param destination Destination to forget > */ > void removeQueueMessageStore(ActiveMQQueue destination); > > /** > * Cleanup method to remove any state associated with the given > destination > * This method does not stop the message store (it might not be > cached). > * @param destination Destination to forget > */ > void removeTopicMessageStore(ActiveMQTopic destination); > > This kind of looks like the functionality you are looking for. This > having said, the method looks empty for most > storage implementations (just done a quick scan), in other word it > seems store dependent. > > Which store are you using ? - It might be that the functionality you > are looking for is just not implemented. > > Best regards > Andreas > > > On Apr 20, 2009, at 5:14 PM, ffrenchm wrote: > >> >> Is this a bug or a misunderstanding ? Do I need to raise a JIRA ? >> >> Thanks >> >> >> ffrenchm wrote: >>> >>> Hello, >>> >>> I'm trying to implement a method to remove queue which will check >>> if the >>> queue has message on it : >>> if yes I throw an exception >>> else I remove the queue thanks BrokerService.removeDestination. >>> >>> The problem I have is that the message store of my non temporary >>> queue is >>> not removed from my AMQ store and then the queue is reloaded at my >>> ActiveMQ restart... >>> >>> I try to find a method from persistenceAdapter like >>> removeQueueMessageStore but I didn't find anything. Do you know a >>> proper >>> way to remove my message store from the activemq store ? Do I need to >>> implement a new method on persistenceAdapter class to achieve this >>> kind of >>> job ? >>> >>> Thanks for all. >>> >>> >>> >>> >> >> -- >> View this message in context: >> http://www.nabble.com/removing-queue-message-store-when-removing-non-temporary-queue-tp23100852p23138714.html >> Sent from the ActiveMQ - User mailing list archive at Nabble.com. >> > > > -- View this message in context: http://www.nabble.com/removing-queue-message-store-when-removing-non-temporary-queue-tp23100852p23154000.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
