Как восстановить ActiveMQ из полного хранилища сохраняемости KahaDb?

Question

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

"Usage (default:store:queue://myqueue:store) percentUsage=101% usage=6254005794, limit=6144430090, ...Stopping producer...to prevent flooding queue..)

Я не смог восстановиться и снова начать потреблять сообщения.

Я пытался идти в activemq.xml, чтобы увеличить мое максимальное использование магазина:

<systemUsage> 
    <systemUsage> 
     <storeUsage> 
      <storeUsage limit="15 gb" /> 
     </storeUsage> 
    </systemUsage> 
    </systemUsage> 

Я также попытался отключить управление потоком с

<policyEntry queue=">" producerFlowControl="false"/> 

Но я все еще получаю такое же сообщение об ошибке.

У меня есть дисковое пространство. В командной строке переопределение не выполняется. Как я могу восстановить и обработать мои сообщения?

Answer 1

В итоге я нашел уродливый (но эффективный) способ обойти это. Если вы подключитесь к activemq через JMX (jconsole), вы можете перейти к mbean org.apache.activemq.Broker и найти атрибут StoreLimit. Вы можете увеличить это значение в JConsole, тогда activemq вскоре перезапустит обработку сообщений.