Ouch. OK. I think a lot of these behaviors might need to be documented a
bit better, or maybe added as edge cases to be fixed in 6.0. I imagine
KahaDB could do this internally but I’m not sure.
I think we might just end up having 2 or 3 queue priorities implemented by
using different physical qu
Was it implemented for topic subscriptions because there is only one
consumer so you don't have to worry about synchronization between threads?
Is that the primary thing that will make implementing this for queues hard?
If so, why is it only available for durable subscriptions but not
non-durable
that is true, the dispatch goes through the cursors in batches once
memory (or the cursor cache) is exhausted.
For durable subs, there is the ability to bypass the paged in messages, see:
https://github.com/apache/activemq/blob/165959e25007271f8cdfdcf72641b9a92483ef40/activemq-unit-tests/src/test/j
No, I was referring to your statement that "due to message cursors, that it
won’t be executed until it’s read into the “maxPageSize window”." I can't
speak to the ability to serve up messages that aren't in the cursor under
those two message stores, though I've never seen anyone refer to such an
a
You mean my statement "KahaDB and LevelDB could probably move it to the
head (I think) but the memory store can not…"
On Mon, May 4, 2015 at 7:31 PM, Tim Bain wrote:
> What you describe matches what I've always understood based on answers from
> people on here (and I've never heard anyone say th
What you describe matches what I've always understood based on answers from
people on here (and I've never heard anyone say that the behavior is
different for any of the data store types), but I can't claim any firsthand
knowledge so if that's not right hopefully someone else will say so.
Tim
On
Let’s say you have a queue with 1M items.. they are all low priority. Then
you add a high priority entry.
I believe, due to message cursors, that it won’t be executed until it’s
read into the “maxPageSize window”.
Is this correct or does it depend on the underlying store?
KahaDB and LevelDB coul
I’m experimenting with filtering by JMS priority for the memory store since
it natively doesn’t support priority. This way I can just implement it in
the consumer.
However, it doesn’t appear to work with the magic JMSPriority header.
I can filter on application specific headers. But when I use
the JMS priority on the message and sort the entire
queue by JMS priority.
Unless I’m missing something, this seems like the most straight forward way
to implement this feature.
Am I missing something.
One issue is the remove() method. Is this actually used? I assume this is
for JMX and the
yTest.testQueues does, my test
> works.
>
> Should JMS Priority work with a consumer already active? Thanks in advance
> for any pointers.
>
> Jeremy
>
> On Thu, Feb 16, 2012 at 8:59 AM, Gary Tully wrote:
>
>> Have a peek at the working unit test on trunk for a c
then starts
a consumer.
When I change MesagePrirityTest.testQueues to start the queue first, it
fails. When I modify my original test to start the consumer after putting
the messages, as the original MesagePrirityTest.testQueues does, my test
works.
Should JMS Priority work with a consumer al
Have a peek at the working unit test on trunk for a comparison with
your test case:
http://svn.apache.org/repos/asf/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/store/MessagePriorityTest.java
On 15 February 2012 20:58, Jeremy Levy wrote:
> I'm attempting to test JMS
I'm attempting to test JMS Priority with ActiveMQ 5.5.1 without much
success and was hoping someone could point out something I am missing.
My test case consists of putting 1000 messages on a queue with a priority
(being set on both the producer and the message) of 0. Followed by puttin
-priority-queues.html
On 27 February 2011 16:36, rliguori wrote:
> Dear ActiveMQ,
>
> I'm tasked to create a JMS Priority test at my current job.
>
> I want to create a test that doesn't duplicate any work that has already
> been done.
>
> Can anyone answer these que
Dear ActiveMQ,
I'm tasked to create a JMS Priority test at my current job.
I want to create a test that doesn't duplicate any work that has already
been done.
Can anyone answer these questions for me:
1) What type of JMS priority testing is covered with the JMS TCK?
2) Where ar
15 matches
Mail list logo
