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

Версия 3.3 от Alexandr Fokin на 2022/11/27 23:17

Скрыть последних авторов
Alexandr Fokin 3.3 1 Клиент для брокера [[Apache ActiveMQ>>doc:Разработка.Брокеры сообщений.Apache Active MQ.WebHome]].
Alexandr Fokin 2.7 2
Alexandr Fokin 2.10 3 ----
4
Alexandr Fokin 1.1 5 Apache.NMS.ActiveMQ
Alexandr Fokin 3.3 6 [[https:~~/~~/www.nuget.org/packages/Apache.NMS.ActiveMQ/ provides OpenWire>>https://www.nuget.org/packages/Apache.NMS.ActiveMQ/ provides OpenWire]]
Alexandr Fokin 1.1 7
8 Apache.NMS.AMQP
Alexandr Fokin 3.3 9 [[https:~~/~~/www.nuget.org/packages/Apache.NMS.AMQP/ provides AMQP>>https://www.nuget.org/packages/Apache.NMS.AMQP/ provides AMQP]]
Alexandr Fokin 1.1 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.