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

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

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