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