Apache.NMS.ActiveMQ
Версия 2.9 от Alexandr Fokin на 2022/11/07 00:46
Apache.NMS.ActiveMQ
https://www.nuget.org/packages/Apache.NMS.ActiveMQ/ provides OpenWire
Apache.NMS.AMQP
https://www.nuget.org/packages/Apache.NMS.AMQP/ provides AMQP
//Основные объекты взаимодействия:
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
)
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
)
2 способа потребления сообщений: 1) handler, 2) явный вызов метода receive.