Re: [Artemis 2.6.0] Messages stuck in queue infinitely

[Justin Bertram <jb...@apache.org>]

The logic for detecting and dealing with slow consumers is in
org.apache.activemq.artemis.core.server.impl.QueueImpl.SlowConsumerReaperRunnable
[1].  Right now it doesn't deal with the use-case you've described.
Contributions are always welcome.


Justin

[1]
https://github.com/apache/activemq-artemis/blob/master/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java#L3472

On Mon, May 28, 2018 at 2:01 AM, Egiptman <gv...@inbox.ru> wrote:

> I have a project working on ActiveMQ. And I plan to migrate it to Artemis.
> Therefore, on the test environment, I installed Artemis and get a situation
> where the messages in one or the other queue "hang." This happens two to
> three times a day in a random order and requires manual actions.
> In this regard, it is very difficult for me to prepare a case for such a
> situation. However, in each specific case, messages begin to accumulate in
> the queue and at the same time there are consumers.
>
> With ActiveMQ, no problems arise. Instances differ only by the broker.
>
> If we talk about this particular case, then yes, in this queue, messages do
> not appear with a frequency of 10 messages per second. However, they can
> accumulate a few thousand, and no messages will be consumed.
> In my opinion, this is a sign of slow consumers.
>
>
>
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-
> f2341805.html
>