You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by ffrenchm <ff...@gmail.com> on 2009/04/17 18:16:03 UTC
removing queue message store when removing non temporary queue
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-tp23100852p23100852.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: removing queue message store when removing non temporary queue
Posted by Andreas Gies <an...@soa-knowledge.net>.
Thanks...
I am using an anonymous connection myself as I am not a committer. I
have
noticed some errors when importing the trunk into my workbench, but I
have
never been asked for a username/password.
This having said, the best import result I do get using the m2eclipse
plugin and import
the modules only as maven projects.
HTH
Andreas
On Apr 21, 2009, at 3:07 PM, ffrenchm wrote:
>
> No problem for raising JIRA and contribute ... moreover because
> after some
> tests my deleted queue appears again after each activemq 5.3snapshot
> restart, so I'll show you a solution (which's certainly not perfect)
> through
> a JIRA :)
>
> Another question : I get the activemq trunk and when importing the
> project
> into my eclipse it ask me a user/password on a connection - the id
> of the
> connection is not defined in the error. So to bypass these problem I
> only
> imported the activemq-core project. Do you know from which activemq
> project
> comes this request ? Is there any anonymous credentials which I can
> use ?
>
> Thanks
>
>
> Andreas Gies wrote:
>>
>> Hi,
>>
>> ok, that explains it; I have just done a quick check against the
>> trunk.
>>
>> AFAIK, corrections are usually contributed to the trunk. The best way
>> to contribute is
>>
>> 1) raise a JIRA
>> 2) provide a test case demonstrating the error / missing feature
>> 3) attach a patch to the issue with the fix
>>
>> This having said, from what I have seen, the AMQStore methods are not
>> empty in trunk,
>> so you might want to check if the trunk already shows the behavior
>> you
>> require.
>> Otherwise you could contribute your solution.
>>
>> Best regards
>> Andreas
>>
>> On Apr 21, 2009, at 1:24 PM, ffrenchm wrote:
>>
>>>
>>> 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.
>>>
>>
>>
>>
>
> --
> View this message in context: http://www.nabble.com/removing-queue-message-store-when-removing-non-temporary-queue-tp23100852p23155724.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
Re: removing queue message store when removing non temporary queue
Posted by ffrenchm <ff...@gmail.com>.
No problem for raising JIRA and contribute ... moreover because after some
tests my deleted queue appears again after each activemq 5.3snapshot
restart, so I'll show you a solution (which's certainly not perfect) through
a JIRA :)
Another question : I get the activemq trunk and when importing the project
into my eclipse it ask me a user/password on a connection - the id of the
connection is not defined in the error. So to bypass these problem I only
imported the activemq-core project. Do you know from which activemq project
comes this request ? Is there any anonymous credentials which I can use ?
Thanks
Andreas Gies wrote:
>
> Hi,
>
> ok, that explains it; I have just done a quick check against the trunk.
>
> AFAIK, corrections are usually contributed to the trunk. The best way
> to contribute is
>
> 1) raise a JIRA
> 2) provide a test case demonstrating the error / missing feature
> 3) attach a patch to the issue with the fix
>
> This having said, from what I have seen, the AMQStore methods are not
> empty in trunk,
> so you might want to check if the trunk already shows the behavior you
> require.
> Otherwise you could contribute your solution.
>
> Best regards
> Andreas
>
> On Apr 21, 2009, at 1:24 PM, ffrenchm wrote:
>
>>
>> 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.
>>
>
>
>
--
View this message in context: http://www.nabble.com/removing-queue-message-store-when-removing-non-temporary-queue-tp23100852p23155724.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: removing queue message store when removing non temporary queue
Posted by Andreas Gies <an...@soa-knowledge.net>.
Hi,
ok, that explains it; I have just done a quick check against the trunk.
AFAIK, corrections are usually contributed to the trunk. The best way
to contribute is
1) raise a JIRA
2) provide a test case demonstrating the error / missing feature
3) attach a patch to the issue with the fix
This having said, from what I have seen, the AMQStore methods are not
empty in trunk,
so you might want to check if the trunk already shows the behavior you
require.
Otherwise you could contribute your solution.
Best regards
Andreas
On Apr 21, 2009, at 1:24 PM, ffrenchm wrote:
>
> 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.
>
Re: removing queue message store when removing non temporary queue
Posted by ffrenchm <ff...@gmail.com>.
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.
Re: removing queue message store when removing non temporary queue
Posted by Andreas Gies <an...@soa-knowledge.net>.
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.
>
Re: removing queue message store when removing non temporary queue
Posted by ffrenchm <ff...@gmail.com>.
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.