Есть ли способ ограничить размер очереди в ActiveMQ. Как и у меня есть четыре очереди: Q1, Q2, Q3, Q4, и я хочу, чтобы Q3 имел 200 МБ сообщений, которые он должен блокировать до тех пор, пока сообщения не будут потребляться, но другие Q1, Q2, Q4 нормально функционируют.Ограничение размера конкретной очереди в ActiveMQ
ответ
Вы можете сделать это, но вам нужно сделать это пошагово.
Существуют различные типы памяти, такие как обычная память «ОЗУ» или дисковое пространство в постоянном хранилище. Вы должны настроить их отдельно. Поскольку, когда память «ОЗУ» отсутствует, сообщение выгружается и извлекается из хранилища (в зависимости от бит конфигурации).
Однако, у вас есть, надеюсь, широкий предел системы, как это:
<systemUsage>
<systemUsage>
<memoryUsage>
<memoryUsage percentOfJvmHeap="70" />
</memoryUsage>
<storeUsage>
<storeUsage limit="100 gb"/>
</storeUsage>
<tempUsage>
<tempUsage limit="50 gb"/>
</tempUsage>
</systemUsage>
</systemUsage>
Учитывая эти записи в качестве отправной точки, вы можете применить per-destination-policies, которые ограничивают определенной очереди (ы). Это устанавливается в процентах от системной памяти, поэтому вам нужно выполнить некоторые вычисления. Используйте storeUsageHighWaterMark
и/или cursorMemoryHighWaterMark
в зависимости от эффекта, который вы хотите. Обратите внимание, что хранилище не используется для непостоянных сообщений.
Для ограничения основной памяти вы также можете использовать параметр memoryLimit
в политике назначения. Это ребенок к системному свойству memoryUsage
.
<policyEntry queue="ANOTHER.>" producerFlowControl="true" memoryLimit="12 kb">
не ограничивает размер очереди до 12 кб
Вы должны отредактировать свой предыдущий пост вместо того, чтобы отправлять по существу то же самое снова. –
- 1. Настойчивость Activemq для конкретной очереди
- 2. Проверьте наличие конкретной очереди в ActiveMQ?
- 3. Политика переопределения ActiveMQ для конкретной очереди
- 4. Ограничение количества сельдерея для конкретной задачи в очереди
- 5. ActiveMQ 5.4.2 класс очереди
- 6. Охраняемые очереди ActiveMQ
- 7. concurrentИнтернет для очереди ActiveMQ
- 8. Автоматическое создание очереди в activemq
- 9. Длина имени очереди в ActiveMQ?
- 10. Обзор очереди фильтра в ActiveMQ
- 11. Ограничение ActiveMQ и префайла
- 12. Что произойдет, если я настрою ограничение размера очереди в rabbitmq?
- 13. Ограничение очереди сообщений MFC
- 14. Ограничение на размер частной очереди MSMQ
- 15. Аутентификация очереди ActiveMQ по сертификату
- 16. ActiveMQ информация об удалении очереди
- 17. создание потребителей в очереди в ActiveMQ
- 18. Query ActiveMQ queue для максимального размера
- 19. Ограничение размера очереди данных - связь с iSeries на Java
- 20. Ограничение памяти (67108864) in activemq
- 21. ActiveMQ 5.9.1 Откат медленного потребителя в очереди
- 22. Как установить ActiveMQ redeliveryPolicy в очереди?
- 23. Время повторной доставки ActiveMQ в очереди?
- 24. Как получить старые сообщения в очереди ActiveMQ
- 25. Ограничение очереди со временем
- 26. Ограничение веса очереди Sidekiq
- 27. Ограничение очереди redis в диапазоне
- 28. Ограничение или ограничение размера файла в C#
- 29. ActiveMQ сообщение "замораживание" на очереди потребляющего
- 30. ActiveMQ: как предотвратить сообщение из «Отправленной очереди»
не это на уровне брокера? как предполагается, на уровень очереди? , поэтому он будет применим ко всем очередям, а не к определенной очереди – Vihar
Это параметры политики назначения, поэтому вы обычно настраиваете политику типа '', Чтобы она охватывала все очереди, начиная с ORDERS и т. Д. Затем примените ограничения памяти для этой очереди (или набора очередей). –
ohh..then it works..maybe настройка именования соглашение будет необходимо для достижения этого – Vihar