Запрос очереди ActiveMQ для размера пика - PullRequest
Новая
       10

Запрос очереди ActiveMQ для размера пика

1 голос
/ 09 февраля 2012

Я пытаюсь написать скрипт для запроса ActiveMQ через оболочку (используя команду activemq-admin query), чтобы определить максимальный размер очереди «на сегодняшний день» (то есть с момента запуска сервера).

Когда я ввожу следующий запрос:

запрос activemq-admin -QQueue = MyQueueName

Я получаю следующий вывод: 

Java Runtime: Sun Microsystems Inc. 1.6.0_25 /usr/java/jdk1.6.0_25/jre
    Heap sizes: current=91456k  free=90978k  max=1358080k
        JVM args: -Dactivemq.classpath=/usr/local/activemq/conf; -Dactivemq.home=/usr    /local/activemq -Dactivemq.base=/usr/local/activemq
ACTIVEMQ_HOME: /usr/local/activemq
ACTIVEMQ_BASE: /usr/local/activemq
Connecting to pid: 3005
DequeueCount = 5930
Name = MyQueueName
MinEnqueueTime = 0
CursorMemoryUsage = 733711
MaxAuditDepth = 2048
Destination = loadable
AverageEnqueueTime = 0.45332837486054295
InFlightCount = 0
MemoryLimit = 1048576
Type = Queue
EnqueueCount = 8067
MaxEnqueueTime = 79
MemoryUsagePortion = 0.0
ProducerCount = 0
UseCache = true
BlockedProducerWarningInterval = 30000
MaxProducersToAudit = 32
CursorFull = false
BrokerName = localhost
PrioritizedMessages = false
ConsumerCount = 0
ProducerFlowControl = true
Subscriptions = []
QueueSize = 2137
MaxPageSize = 200
CursorPercentUsage = 69
DispatchCount = 620
MemoryPercentUsage = 69
ExpiredCount = 0

Когда я захожу в веб-консоль, я вижу 2137 сообщения, помещенные в очередь в MyQueueName, что соответствует полю QueueSize в этих выходных данных.

Но в какой-то момент (во время выполненияJava-приложение) Я увидел более 3000 сообщений в этой очереди.

Предоставляет ли ActiveMQ метрику для получения " глобального максимального размера очереди "?То есть максимальное количество помещенных в очередь сообщений в любой момент времени?

Заранее спасибо!

1 Ответ

0 голосов
/ 09 февраля 2012

Был ли брокер остановлен / запущен с тех пор? Я только что попробовал себя, и если я остановлю брокера, данные об очереди уйдут, что для меня звучит как ошибка. Вы должны спросить об этом на форумах ActiveMQ. Кстати, я использую версию 5.5.1, которая является последней стабильной, как они говорят, также эта ошибка совсем не нова, посмотрите на как-то связанные AMQ-1367.

Опять же, ваш лучший выбор на форуме ActiveMQ:

ActiveMQ forum

Ура, Евгений.

...