Org.apache.activemq.artemis.jms.client.activemqmessageconsumer.receive () застрял на timed_waiting ⇐ JAVA

[Anonymous]

Стороннее многопоточное приложение взаимодействует с удаленной очередью ActiveMQ и застряет с темами, ожидающими по адресу: < /p>

Код: Выделить всё

java.lang.Thread.State: TIMED_WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.receive(ClientConsumerImpl.java:258)
- locked  (a org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl)
at org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.receive(ClientConsumerImpl.java:385)
at org.apache.activemq.artemis.jms.client.ActiveMQMessageConsumer.getMessage(ActiveMQMessageConsumer.java:198)
at org.apache.activemq.artemis.jms.client.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:118)
...(...:384)

Я декомпилировал приложение и просмотр журналов трассировки, и кажется, что метод queuereceiver.receive () не получает/не смотрит такое же количество сообщений, возвращаемых queuebrowser .
/* 375 */ queueBrowser = queueSession.createBrowser(queue, messageSelector);
/* 376 */ Enumeration e = queueBrowser.getEnumeration();
/* 377 */ int iMesgCount = 0;
/* 378 */ while (e.hasMoreElements()) {
/* 379 */ iMesgCount++;
/* 380 */ e.nextElement();
/* */ }
/* 382 */ queueReceiver = queueSession.createReceiver(queue, messageSelector);
/* 383 */ for (int i = 0; i < iMesgCount; i++) {
/* 384 */ Message ipMessage = queueReceiver.receive();
/* */ }
< /code>
Почему это может быть, и есть ли что -нибудь, что я могу сделать, чтобы добавить контроль параллельного управления вокруг объектов ActiveMQ? (Я не верю, что есть какие -либо другие потоки или процессы, удаляющие сообщения из очереди - я считаю, что проблема является многопоточным использованием объектов ActiveMQ.)

Подробнее здесь: https://stackoverflow.com/questions/795 ... ve-stuck-a