PublishAMQP
Описание
Создает сообщение AMQP из содержимого FlowFile и отправляет его в обменник AMQP. В типичной модели обмена AMQP сообщение, отправленное в обменник AMQP, будет маршрутизировано на основе "ключа маршрутизации" к своему конечному пункту назначения в очереди (связке). Если из-за какой-либо ошибки конфигурации связь между обменником, ключом маршрутизации и очередью не настроена, сообщение не достигнет конечного пункта назначения и вернется (т. е. данные не попадут в очередь). В таком случае в журнале приложения и бюллетене будет зафиксировано соответствующее сообщение, а FlowFile будет отправлен в связь "failure".
Теги
amqp, rabbit, put, message, send, publish
Свойства
| Название | Описание |
|---|---|
| Exchange Name | Имя биржи AMQP, на которую будут отправляться сообщения. Обычно указывается администратором AMQP (например, 'amq.direct'). Это необязательное свойство. Если оно не указано, сообщения будут отправляться на биржу AMQP по умолчанию. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Routing Key | Имя ключа маршрутизации, который будет использоваться AMQP для маршрутизации сообщений из очереди в очередь (очереди) назначения. Обычно задается администратором (например, 'myKey'). Если сообщения отправляются в очередь по умолчанию, это свойство соответствует имени очереди назначения, в противном случае необходимо установить привязку от очереди к очереди назначения с помощью ключа маршрутизации (обычно это делает администратор AMQP). Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Header Separator | Символ, используемый для разделения пар «ключ-значение» в заголовках. Значение должно состоять только из одного символа. В противном случае вы получите сообщение об ошибке |
| Brokers | Список известных брокеров AMQP, разделённых запятыми, в формате <хост>:<порт> (например, localhost:5672). Если это свойство задано, имя хоста и порт игнорируются. Включайте только хосты из одного кластера AMQP. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Host Name | Сетевой адрес брокера AMQP (например, localhost). Если задано свойство Brokers, это свойство игнорируется. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Port | Числовое значение, определяющее порт брокера AMQP (например, 5671). Если задано свойство Brokers, то это свойство игнорируется. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Virtual Host | Имя виртуального хоста, который отделяет систему AMQP для повышения безопасности. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| User Name | Имя пользователя, используемое для аутентификации и авторизации. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Password | Пароль, используемый для аутентификации и авторизации. Чувствительный параметр: true |
| AMQP Version | Версия AMQP. В настоящее время поддерживается только AMQP v0.9.1. |
| SSL Context Service | Служба контекста SSL, используемая для предоставления информации о сертификате клиента для подключений TLS/SSL. |
| Use Client Certificate Authentication | Аутентификация с использованием сертификата SSL, а не имени пользователя и пароля. |
Взаимосвязи
- success: Все файлы Flow, отправляемые в пункт назначения AMQP, направляются в эту связь.
- failure: Все файлы Flow, которые не могут быть направлены в пункт назначения AMQP, направляются в эту связь.