Подключенный потребитель ActiveMQ не использует сообщения

#c# #asp.net #activemq

#c# #asp.net #activemq

Вопрос:

Я использую NuGet для работы с ActiveMQ https://activemq.apache.org/components/nms / Также пробовал Apache.NMS.ActiveMQ.NetStd. Ситуация такова, что прослушиватель успешно подключается к брокеру, и в веб-консоли это можно увидеть в соответствующей очереди. Но сообщения из очереди не потребляются. Без каких-либо ошибок.

Что — то вроде этого: введите описание изображения здесь

Потребительский кодекс. Это AspNet HostedService: введите описание изображения здесь

Связанный с tcp://... : введите описание изображения здесь

Создание соединения и сеанса: введите описание изображения здесь

Я не получаю никаких исключений, вообще ничего. Никакие сообщения не доставляются слушателю. В чем может быть проблема?

Ответ №1:

Проблема была в queuePrefetch, асинхронный потребитель не работает со значением 0, в этом случае вы можете использовать только синхронный потребитель или увеличить значение queuePrefetch. введите описание изображения здесь