Счетчик потребителей/счетчик ожидающих сообщений из очереди + ActiveMQ + Java

Мне нужно разработать утилиту на Java, которая будет использовать API ActiveMQ для получения свойств очереди/темы, чтобы получить количество потребителей/количество ожидающих сообщений, а также есть ли способ удалить любое сообщение через код из очереди?


spring-data-mongodb activemq
person Jay Rupera    schedule 16.09.2015    source источник

Ответы (2)


arrow_upward
2
arrow_downward

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

Что касается удаления/удаления любого конкретного сообщения из очереди, я бы рекомендовал не делать это в отдельной программе, а просто позволить вашим потребителям сообщений обрабатывать такие сообщения. Я думаю, это был бы более удобный подход.

person hemant1900    schedule 17.09.2015

arrow_upward
0
arrow_downward

Все приведенные ниже сведения относятся к Queue API ActiveMQ, вы также можете найти похожие вещи по теме.

  • Ни одно из ожидающих сообщений не может быть найдено с помощью getMessages().size()
  • Ни один из потребителей не может быть найден getConSumers().size()
  • да, мы можем удалять сообщения в очередь из Java-кода, но для этого нам нужен MessageReference или messageId или подходящий message Selector, вы можете посмотреть официальную документацию по removeMessage(...) и removeMatchingMessages(...) здесь

надеюсь это поможет!

Удачи!

person Vihar    schedule 17.09.2015