,
B, A1, B1, A2, B2 or as A, B, A1, A2, B1, B2? That is, do both consumers
have Exclusive=false?
Tim
On Dec 4, 2017 1:11 PM, "Chinna" wrote:
> I have a scenario like more than 70 messages in the queue with 2 active
> consumers but only one consumer is picking the messages wi
I have a scenario like more than 70 messages in the queue with 2 active
consumers but only one consumer is picking the messages with Dispatched
queue size is 2 and another consumer is not picking any messages from the
queue,
"Connection IDClient ID : ID:.com-
sh and consume messages on the queue, (about 4 messages),
> the Dispatched Queue increase to 1000 then teh Pending queue increase to 20
> 000 or more messages.
>
> The messages are consume and suddenly, the Dispatched Queue decrease to 0
> messages although there are some thousan
Hi, i upgraded yesterday to 5.9.0 version and i can't reproduce the problem
of stuck messages.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Stuck-messages-Pending-Queue-Size-stopped-to-be-dispatched-to-Dispatched-Queue-Size-tp4673046p4673153.html
Sent fro
Hi,
we're using AMQ 5.8.0 with LevelDB storage.
We have a publisher and a consumer on a persistant durable topic.
When we publish and consume messages on the queue, (about 4 messages),
the Dispatched Queue increase to 1000 then teh Pending queue increase to 20
000 or more messages.
(context: for active durable topic subscribers. We're not using queues)
What is the definition of 'Dispatched Queue Size' that appears on the
web console?
What broker and/or consumer behaviors can cause it to increase?
The definitions for the others I have are:
Dispatched Coun
e ack's are out of order from
receive's.
That's quite likely to happen as different messages take different amounts
of time to process.
-Original Message-
From: Christian Posta [mailto:christian.po...@gmail.com]
Sent: Friday, April 26, 2013 5:54 PM
To: users@activemq.apac
I duplicated this behavior on RedHat Linux with 5.6.0 and sleep(600);
To recap at this point:
Sleep(500) works fine, Sleep(600) gets an exception, Sleep(1000) misses the
1st message.
So it's not platform dependent. Given the error I see I don't think it's
necessarily related to my original proble
q.apache.org
Subject: Re: Dispatched Queue Size
Let us know what happens if you run on a LAN. If you can post your
code/configs, or better yet, create a unit test that shows this, it'll be
much easier to tell you what's going on.
On Fri, Apr 26, 2013 at 8:28 AM, mdblack98 wrote:
>
uot;);
}
}
}
-Original Message-
From: Christian Posta [mailto:christian.po...@gmail.com]
Sent: Friday, April 26, 2013 5:54 PM
To: users@activemq.apache.org
Subject: Re: Dispatched Queue Size
Let us know what happens if you run on a LAN. If you can post your
code/configs, or better yet, create a unit test that shows this, it'll be
much easier to tell you what's going on.
nswer to this?
> I can reproduce that at any time quite easily. It happens continuously
> while the client is running. A little less than 1% of the total number of
> messages end up not showing Dequeued but they are actually being processed
> and ack'd.
> The "Dispatched Qu
.
The "Dispatched Queue Size" never decrements, I zero it out by deleting the
topic and shortly thereafter it gets stuck again not showing a few messages
be dequeued.
If figure this has to be a timing issue because it's on a WAN.
How do you address, acknowledge, or re-receive the out
tuation is that Dispatched Queue Size increments once in a while and
then never decrements below a minimum value EVER.
If I stop and restart the client that queue size stays the same.
But.I have received all the messages and acknowledged them (though like I
said that might've taken a second or more)
gt; >> the queue - e.g. if there are still 10 items left in the queue and I
> want
> >> to get 10, I only get 5 or so.
> >>
> >> I've already found the prefetchSize configuration and set it to 0 (also
> >> tried 1), but still the same problem.
> >
; The problem we have now is that we are not able to fetch all items from
>> the queue - e.g. if there are still 10 items left in the queue and I want
>> to get 10, I only get 5 or so.
>>
>> I've already found the prefetchSize configuration and set it to 0 (also
>&g
t to 0 (also
> tried 1), but still the same problem.
> The problem seems to be that each consumer has an internal 'dispatched
> queue' which already has some entries and consumer A has no possibility to
> access the dispatched queue of consumer B.
>
> For example
maybe take the time to write a simple test case to isolate the problem
2010/1/21 Christoph Kutzinski
>
> http://old.nabble.com/Problem-with-%27dispatched-queue%27-td27223270.html
>
> No one got an idea what's wrong here?
> Any directions where I could get more information? E.g.
> - logging outpu
http://old.nabble.com/Problem-with-%27dispatched-queue%27-td27223270.html
No one got an idea what's wrong here?
Any directions where I could get more information? E.g.
- logging output
- JMX console
- source code?
Christoph
--
View this message in context:
http://old.nabble.com/Problem-with
An additional observation:
The size of the dispacthed queue seems also to be equal the (largest) number
of messages I received in a row. E.g. if I received 5 message the webconsole
looks like this:
"Enqueues 10; Dequeues 5; Dispatched 10; Dispatched Queue 5"
If I receive 10 messages
No,
sorry no simple testcase and currently don't have the time to create one.
As I can the see from the 'Prefetch 0' in the web console, prefetchSize
seems to get noticed from ActiveMQ. However, it doesn't seem to have any
effect on the dispatched queue.
I can only provi
ize configuration and set it to 0 (also
> tried 1), but still the same problem.
> The problem seems to be that each consumer has an internal 'dispatched
> queue' which already has some entries and consumer A has no possibility to
> access the dispatched queue of consumer B.
the queue and I want to get
10, I only get 5 or so.
I've already found the prefetchSize configuration and set it to 0 (also tried
1), but still the same problem.
The problem seems to be that each consumer has an internal 'dispatched queue'
which already has some entries and co
Pending Queue Size The number of messages in the queue that have yet to be
delivered to any client
Dispatched Counter The number of message in the queue that have been
delivered to a client, but not yet acknowledged
Enqueue Counter The number of messages that have been sent to this queue
Dequ
Help me!
I have no idea about these words.
--
View this message in context:
http://www.nabble.com/What-is-the-meaning-about-%22Pending-Queue-Size%22%2C-%22Dispatched-Queue-Size%22%2C%22Dispatched-Counter%22%2C%22Enqueue-Counter%22%2C%22Dequeue-Counter%22-in-JMS-web-console%2C-THX%21-tp21906622p
24 matches
Mail list logo
