On 09/02/2015 02:32 AM, spamtrap wrote:
> Is it possible for a consumer to only consume messages above a certain
> priority, rather than just get them in priority order? Is so how can
> this be done?
>
> I am using ActiveMQ-CPP - latest version.
>
>
>
Have a look at JMS message selectors, they allo
I had thought that once the message cursor became full of messages for the
other selector (because there's only one cursor for a given destination),
no more messages could be paged in till some of those others were consumed,
but that might not be right (and I'm curious to hear what your code
inspec
tbain98 has the right idea. And that raises an interesting question
regarding messages on-disk and not in-memory - I need to review to see how
that operates.
Here's how I expect it to work: the consumer with it's exclusive selector
will get all pending messages which match its selector regardless
I've never used message priority, so most of what I know comes from reading
what others like Art have written about it, but I believe that as long as
all of those messages fit in memory or in the cursor you're using to read
from the persistent store (if applicable), the selectors will cause
consume
gtully wrote
> policyEntry queue="xxx" useCache="false"
> expireMessagesPeriod="0"queuePrefetch="1"
Gary,Even tough we configured our queue using all these options, we still
have problems when a JDBC persistence adapter is used : 1. sometimes low
priority messages are consumed although there are t
The fix will be in 5.6, have a peek at
https://issues.apache.org/jira/browse/AMQ-3596, you can validate it in
tonight's 5.6-SNAPSHOT or try one of the workarounds.
On 14 November 2011 17:33, Mihai Osian wrote:
> Hello,
>
> I am trying to enable priority consumption and I can't seem to get it
>
hmm. that is a problem. If you use persistent delivery,
DeliveryMode.PERSISTENT or pass -Ddurable=true to the ant producer
task, the priority order will be respected.
I ran a quick variant of the
org.apache.activemq.store.MessagePriorityTest.testQueues from
activemq-core with non persistent delive
is enabled) structure to hold
the messages that are waiting to be dispatched.
From: Gary Tully [via ActiveMQ]
[mailto:ml-node+3713800-2029387266-139...@n4.nabble.com]
Sent: Tuesday, August 02, 2011 5:15 PM
To: Urciolo, Kevin J (IS)
Subject: Re: EXT :Re: Message Priority In 5.5.0-fuse-00-43
If
cts with the
> messages pending dispatch in any way. I could not see an interaction.
>
> Kevin
>
>
> From: Urciolo, Kevin J (IS)
> Sent: Friday, July 29, 2011 11:58 AM
> To: 'Gary Tully [via ActiveMQ]'
> Subject: RE: EXT :Re: Message Priority In 5.5.0-fuse-00-4
, July 29, 2011 11:58 AM
To: 'Gary Tully [via ActiveMQ]'
Subject: RE: EXT :Re: Message Priority In 5.5.0-fuse-00-43
I changed from a listener to a consumer.receive and set the prefetch to 0. The
behavior is the same as with the message listener and prefetch set to 1.
From: Gary Tully [vi
, Kevin J (IS)
Subject: Re: EXT :Re: Message Priority In 5.5.0-fuse-00-43
if you use prefetch=0, do you still see that behavior?
On 28 July 2011 21:07, urciolo <[hidden
email]> wrote:
> Hello, I took a look at the test cases. I modified one a bit to reproduce
> the behavior I am seein
//ActiveMQMessageConsumer consumer = (ActiveMQMessageConsumer)
> consumerSession.createConsumer(dest);
>
>
>
> From: Gary Tully [via ActiveMQ]
> [mailto:ml-node+3696786-639262666-139...@n4.nabble.com]
> Sent: Tuesday, July 26, 2011 3:39 PM
> To: Urciolo, Kevin J (IS)
umer consumer = (ActiveMQMessageConsumer)
consumerSession.createConsumer(dest);
From: Gary Tully [via ActiveMQ]
[mailto:ml-node+3696786-639262666-139...@n4.nabble.com]
Sent: Tuesday, July 26, 2011 3:39 PM
To: Urciolo, Kevin J (IS)
Subject: Re: EXT :Re: Message Priority In 5.5.0-fuse-00-43
so that is not exp
-639262666-139...@n4.nabble.com]
Sent: Tuesday, July 26, 2011 3:39 PM
To: Urciolo, Kevin J (IS)
Subject: Re: EXT :Re: Message Priority In 5.5.0-fuse-00-43
so that is not expected. Have a peek over one of the message priority
test cases to see if there is something different from your scenario,
you
, Kevin J (IS)
> Subject: EXT :Re: Message Priority In 5.5.0-fuse-00-43
>
> if you have concurrent producers and consumers, then the prefetch has
> an effect as a consumer will get a batch of messages which will get
> delivered with relative priority.. but there may be others with
+3696461-369868383-139...@n4.nabble.com]
Sent: Tuesday, July 26, 2011 1:38 PM
To: Urciolo, Kevin J (IS)
Subject: EXT :Re: Message Priority In 5.5.0-fuse-00-43
if you have concurrent producers and consumers, then the prefetch has
an effect as a consumer will get a batch of messages which will get
if you have concurrent producers and consumers, then the prefetch has
an effect as a consumer will get a batch of messages which will get
delivered with relative priority.. but there may be others with higher
priority arriving on the broker.
Use prefetch=1|0 to circumvent that.
On 26 July 2011 18:
https://issues.apache.org/activemq/browse/AMQ-2949
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Message-priority-tp2717868p2718918.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Thanks Dejan
Here is the link to the the issue I've created :
https://issues.apache.org/activemq/browse/AMQ-2949
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Message-priority-tp2717868p2718912.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Can you raise a Jira issue and attache the test case there?
Cheers
--
Dejan Bosanac - http://twitter.com/dejanb
Open Source Integration - http://fusesource.com/
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net
On Tue, Sep 28, 2010 at 10:25 PM, math_baril wr
Thank you for your response.
Luana
James.Strachan wrote:
>
> 2009/2/16 Luana87 :
>>
>>
>>
>> James.Strachan wrote:
>>>
>>> 2009/2/16 Luana87 :
Hello,
I'm starting to use ActiveMQ v5.2.0 and I need to prioritize messages
sent
from only one producer.
I am wondering
2009/2/16 Luana87 :
>
>
>
> James.Strachan wrote:
>>
>> 2009/2/16 Luana87 :
>>>
>>> Hello,
>>> I'm starting to use ActiveMQ v5.2.0 and I need to prioritize messages
>>> sent
>>> from only one producer.
>>> I am wondering which the correct way is.
>>> In particular I would like to understand which t
James.Strachan wrote:
>
> 2009/2/16 Luana87 :
>>
>> Hello,
>> I'm starting to use ActiveMQ v5.2.0 and I need to prioritize messages
>> sent
>> from only one producer.
>> I am wondering which the correct way is.
>> In particular I would like to understand which the difference is between
>> messa
2009/2/16 Luana87 :
>
> Hello,
> I'm starting to use ActiveMQ v5.2.0 and I need to prioritize messages sent
> from only one producer.
> I am wondering which the correct way is.
> In particular I would like to understand which the difference is between
> message.setJMSPriority(priority) and sender.s
24 matches
Mail list logo
