Блок-приёмник данных: выполняет запись в топик или очередь RabbitMQ.
Тип брокера: RabbitMQ
Входящий тип данных: DaJet.Flow.RabbitMQ.Message
Исходящий тип данных: НЕТ
Входящий тип данных можно получить при помощи трансформации типа данных DaJet.Flow.Payload,
используя блок-трансформатор DaJet.Flow.RabbitMQ.PayloadToMessageTransformer.
Настройки блока Producer (подробнее в документации VMware):
| Опция | Значение | Пример |
|---|---|---|
| Target | URI сервера и виртуального хоста RabbitMQ | amqp://guest:guest@localhost:5672/%2F |
| Exchange | Имя топика на сервере RabbitMQ для записи сообщений. Если не указано, то опция RoutingKey == имя очереди. |
dajet-topic |
| RoutingKey | Имя очереди или ключ маршрутизации (см. опцию Exchange). | just-for-you |
| CC | Дополнительные ключи маршрутизации, которые видны получателям. Указываются через запятую в формате csv. Подробнее в документации VMware |
node-0,node-1,node-2 |
| BCC | Дополнительные ключи маршрутизации, которые не видны получателям. Указываются через запятую в формате csv. Подробнее в документации VMware |
node-3,node-4,node-5 |
| Mandatory | Если опция включена (true) а маршрутизация невозможна (нет очереди), то сервер RabbitMQ вернёт такое сообщение назад клиенту с ошибкой. Если опция выключена (false), тогда сообщение будет отброшено сервером RabbitMQ, а клиенту сообщено об успешной доставке. |
false |
| Sender | Идентификатор отправителя для заполнения заголовка "AppId". | trade-main-node |
| MessageType | Идентификатор типа сообщения для заполнения заголовка "Type". | Справочник.Номенклатура |