ActiveMQ - сообщения о состоянии ожидания

Question

Существует огромное количество ожидающих сообщений, даже если выделено 8 потребителей, например: если имеется 80000 сообщений, то только 70000 обрабатываются, а 10000 ожидают.

Нет проблем с ограничением памяти, но эта проблема встречается чаще

Я обнаружил, что установка предопределенного предела поможет, но все равно он не работает, но при перезапуске системы, включая сервер (JBOSS), ожидающие сообщения будут потребляться потребителями

Кто-нибудь еще сталкивался с такой же проблемой и нашел решение этой проблемы? Пожалуйста помоги!

Answer 1

Метод onMessage() был synchronized, который не позволял бы нескольким потокам (сообщениям) входить в блок и обрабатываться, поскольку очередь результатов заполнялась, а сообщения проходили свой предел времени ожидания и в конечном итоге находились в очередь. Это было проблемой для меня.