Сообщения JMS с ActiveMQ
Здесь я покажу, как настроить составную очередь в ActiveMQ с сообщениями хранилища для базы данных Oracle на SpringBoot и Spring JMS.
Составная очередь
Составная очередь, связанная с отношением один ко многим. Сообщение отправляется в одну очередь, а затем копируется в каждую очередь, которую мы указываем в activemq.xml. В этом примере в очереди две: физ.q1 и физ.q2.
Настройка ActiveMQ
Скачать ActiveMQ и установить его по этому гайду. При написании этого примера это было ActiveMQ 5.15.6 Release.
Измените файл activemq.xml в каталоге /conf в соответствии с приведенными ниже изменениями:
После запуска ActiveMQ в базе данных будут созданы три таблицы.
Посмотреть сообщения можно на странице администратора: http://localhost:8161/admin
Примеры кода
Добавьте зависимости в pom.xml
Пример простого производителя, который отправляет одно сообщение за 5 секунд:
Пример простого потребителя двух очередей:
Весь пример вы можете увидеть в репозитории github.
