Как получить старые сообщения в очереди ActiveMQ

Question

Я работаю над приложением ActiveMQ, где iam использует пользователя, который использует Session.CLIENT_ACKNOWLEDGE.

Iam отправляет сообщения, полученные из очереди в потребитель, в webservice. Если я надену message.acknowledge(), все сообщения, отправленные в webservice, вернутся в очередь в состоянии очереди.

Мой вопрос заключается в том, чтобы получить сообщения снова из очереди и использовать it.I используется ретроактивный = истинный и попытался Redelivery также, но все они терпят неудачу.

Как этого избежать.

Answer 1

Если вы используете message.acknowledge(), все потребляемые сообщения снова недоступны в той же очереди, потому что считаются поставленными!

Вы можете объяснить, почему вам нужно снова потреблять уже принятые сообщения. retroactive предназначен для потребителей, которые были в автономном режиме и при запуске подключения для приема сообщений, отправленных до подключения.

В этом случае вам необходимо настроить политику предварительной выборки для потребителя до 400. Вы можете прочитать, чтобы понять концепцию http://activemq.apache.org/what-is-the-prefetch-limit-for.html

Если вы хотите обрабатывать сообщения один за другим с помощью счетчика, вам необходимо установить предварительную выборку в 1 и подтвердить каждое сообщение, когда вы лечите 200, которые вы не признаете.