Свойства узла процесса интеграции вида «RabbitMqИсточник»
Узел этого вида получает сообщения от информационной системы, являющейся брокером сообщений RabbitMQ из указанной очереди, привязанной к указанному обмену (Exchange).
RabbitMQ использует протокол AMQP, основное отличие которого от JMS в том, что сообщение от системы-отправителя доставляется не непосредственно в очередь, а через Exchange, в котором определяется, в какую очередь будет доставлено сообщение.
Свойства узла
- ОбновлениеМетрик
- Обработчик, внутри которого можно обновлять метрики, добавленные в проект
разработчиком.
Пример:
// Разработчик добавил в проект метрику «СчетчикВУзле». Тогда обновить метрику в узлах // можно следующим образом: метод ОбновлениеМетрик(Контекст: МойПроцессИнтеграции.КонтекстВызова, Сообщение: МойПроцессИнтеграции.Сообщение) пер СчетчикВУзле = МойПроцессИнтеграции.Метрики["СчетчикВУзле"] СчетчикВУзле.Обновить(Сообщение.УзлыПути.Текущий.Узел.Имя, 1) ;
- ИмяКанала
- Имя очереди, из которой получаются сообщения.
Пример использования
Контекст: Осуществляется отправка сообщения из RabbitMQ в систему на платформе «1С».
Задача: Забрать сообщение из очереди RabbitMQ и передать его дальше по схеме процесса интеграции.
Решение: Используем узел «RabbitMqИсточник» чтобы подключиться к очереди сообщений, созданной внутри RabbitMQ. Когда в очереди появляется новое сообщение, считывает его и передает дальше по схеме в узел Канал1СНазначение («ВОфис»). Таким образом, сообщение сохраняется в новую очередь, которая создается в . Из этой очереди сообщение доставляется получателю, который входит в группу участников «Офис».