Apache ActiveMQ
Версия 6.1 от Alexandr Fokin на 2021/12/24 11:34
Основные объекты взаимодействия:
1) IConnection
connection.Start()
2) ISession
connection.CreateSession()
3) IQueuq
session.GetQueue(name)
4.1) IMessageProducer
session.CreateProducer(session)
4.2) IMessageConsumer
session.CreateConsumer(
session,
selector,
false
)
Клиент:
https://www.nuget.org/packages/Apache.NMS.ActiveMQ/ provides OpenWire
https://www.nuget.org/packages/Apache.NMS.AMQP/ provides AMQP
Материалы:
Понимание брокеров сообщений. Изучение механики обмена сообщениями посредством ActiveMQ и Kafka. Глава 2. ActiveMQ
https://habr.com/ru/post/471268/
Документация:
https://activemq.apache.org/components/nms/msdoc/1.6.0/vs2005/Output/html/N_Apache_NMS.htm
Выборка сообщений из очереди по условию. Selector
https://activemq.apache.org/selectors