Исходный код вики Apache.NMS.ActiveMQ

Версия 2.9 от Alexandr Fokin на 2022/11/07 00:46

Скрыть последних авторов
Alexandr Fokin 2.7 1
2
Alexandr Fokin 1.1 3 Apache.NMS.ActiveMQ
4 https://www.nuget.org/packages/Apache.NMS.ActiveMQ/ provides OpenWire
5
6 Apache.NMS.AMQP
7 https://www.nuget.org/packages/Apache.NMS.AMQP/ provides AMQP
8
Alexandr Fokin 2.7 9 ----
Alexandr Fokin 1.1 10
Alexandr Fokin 2.1 11 {{code language="c#"}}
12 //Основные объекты взаимодействия:
Alexandr Fokin 1.1 13
14 1) IConnection
15 connection.Start()
16
17 2) ISession
18 connection.CreateSession()
19
20 3) IQueuq
21 session.GetQueue(name)
22
23 4.1) IMessageProducer
24 session.CreateProducer(session)
25
26 4.2) IMessageConsumer
27 session.CreateConsumer(
Alexandr Fokin 2.6 28 session,
Alexandr Fokin 2.5 29 selector,
Alexandr Fokin 2.1 30  false
31  )
32 {{/code}}
Alexandr Fokin 2.7 33
34 ----
35
36 2 способа потребления сообщений: 1) handler, 2) явный вызов метода receive.