Превышен предел памяти ActiveMQ

Question

Я пытаюсь настроить ActiveMQ для следующего поведения: когда брокер превышает свой предел памяти, он должен хранить сообщение в хранилище постоянного хранения. Если используется следующая конфигурация:

BrokerService broker = new BrokerService(); 
    broker.setBrokerName("activemq"); 
    KahaDBPersistenceAdapter persistence = new KahaDBPersistenceAdapter(); 
    persistence.setDirectory(new File(config.getProperty("amq.persistenceDir", "amq"))); 
    broker.setPersistenceAdapter(persistence); 
    broker.setVmConnectorURI(new URI("vm://activemq")); 
    broker.getSystemUsage().getMemoryUsage().setLimit(64 * 1024 * 1024L); 
    broker.getSystemUsage().getStoreUsage().setLimit(1024 * 1024 * 1024 * 100L); 
    broker.getSystemUsage().getTempUsage().setLimit(1024 * 1024 * 1024 * 100L); 
    PolicyEntry policyEntry = new PolicyEntry(); 
    policyEntry.setCursorMemoryHighWaterMark(50); 
    policyEntry.setExpireMessagesPeriod(0L); 
    policyEntry.setPendingDurableSubscriberPolicy(new StorePendingDurableSubscriberMessageStoragePolicy()); 
    policyEntry.setMemoryLimit(64 * 1024 * 1024L); 
    policyEntry.setProducerFlowControl(false); 
    broker.setDestinationPolicy(new PolicyMap()); 
    broker.getDestinationPolicy().setDefaultEntry(policyEntry); 
    broker.setUseJmx(true); 
    broker.setPersistent(true); 
    broker.start(); 

Однако это не работает. ActiveMQ по-прежнему потребляет столько памяти, сколько необходимо для хранения полной очереди. Я также попытался удалить PolicyEntry, что заставило брокера остановить производителей после достижения предела памяти. Я не мог найти ничего в документации о том, что я делаю неправильно.

Answer 1

мы используем storeCursor и установить ограничение памяти следующим образом ... это будет ограничить объем памяти для всех очередей в 100MB ...

<destinationPolicy> 
     <policyMap> 
      <policyEntries> 
       <policyEntry queue=">" producerFlowControl="false" memoryLimit="100mb"> 
        <pendingQueuePolicy> 
         <storeCursor/> 
        </pendingQueuePolicy> 
       </policyEntry> 
      </policyEntries> 
     </policyMap> 
    </destinationPolicy> 

убедитесь, что вы установите «пункты назначения», что ваш политика должна применяться в отношении ... в моих примерах XML это делается с помощью queue=">", но ваш пример использует new PolicyMap() ... попробуйте позвонить policyEntry.setQueue(">") вместо того, чтобы обратиться ко всем очередям или добавить конкретные направления к вашему PolicyMap и т.д.

см. этот тест для полного примера ...

https://github.com/apache/activemq/blob/master/activemq-unit-tests/src/test/java/org/apache/activemq/PerDestinationStoreLimitTest.java