PublishJMS
Описание
Создает JMS-сообщение из содержимого файла потока и отправляет его в назначение JMS (очередь или тему) как BytesMessage или TextMessage JMS. Атрибуты файла потока будут добавлены как заголовки и/или свойства JMS к исходящему JMS-сообщению.
Теги
jms, put, message, send, publish
Свойства
| Название | Описание |
|---|---|
| Connection Factory Service | Служба контроллера, используемая для получения фабрики подключений. В качестве альтернативы для настройки фабрики подключений можно использовать свойства 'JNDI *' или 'JMS *'. |
| Destination Name | Имя назначения JMS. Обычно указывается администратором (например, 'topic://myTopic' или 'myTopic'). Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Destination Type | Тип назначения JMS. Может быть одним из "QUEUE" или "TOPIC". Обычно указывается администратором. По умолчанию используется "QUEUE" |
| User Name | Имя пользователя, используемое для аутентификации и авторизации. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Password | Пароль, используемый для аутентификации и авторизации. Чувствительный параметр: true |
| Connection Client ID | Идентификатор клиента, который должен быть установлен при подключении, если он установлен. Для долговременных пользователей без общего доступа это обязательно, для всех остальных это необязательно, обычно для пользователей с общим доступом это нежелательно устанавливать. Пожалуйста, смотрите спецификацию JMS для получения более подробной информации Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Message Body Type | Тип тела сообщения JMS для создания. |
| Character Set | Название набора символов, используемого для создания или интерпретации текстовых сообщений. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Allow Illegal Characters in Header Names | Указывает, следует ли отправлять брокеру JMS недопустимые символы в именах заголовков. Обычно это дефисы и точки. |
| Attributes to Send as JMS Headers (Regex) | Задает регулярное выражение, определяющее имена атрибутов FlowFile, которые должны отправляться в виде заголовков JMS |
| Record Reader | Средство чтения записей для разбора входящего файла Flow на записи. |
| Record Writer | Средство записи записей для сериализации записей перед их публикацией в виде сообщения JMS.This Property is only considered if the [Record Reader] Property has a value specified. |
| JNDI Initial Context Factory Class | The fully qualified class name of the JNDI Initial Context Factory Class (java.naming.factory.initial). Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| JNDI Provider URL | The URL of the JNDI Provider to use as the value for java.naming.provider.url. See additional details documentation for allowed URL schemes. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| JNDI Name of the Connection Factory | The name of the JNDI Object to lookup for the Connection Factory. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| JNDI / JMS Client Libraries | Specifies jar files and/or directories to add to the ClassPath in order to load the JNDI / JMS client libraries. This should be a comma-separated list of files, directories, and/or URLs. If a directory is given, any files in that directory will be included, but subdirectories will not be included (i.e., it is not recursive).This property expects a comma-separated list of resources. Each of the resources may be of any of the following types: directory, URL, file. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| JNDI Principal | The Principal to use when authenticating with JNDI (java.naming.security.principal). Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| JNDI Credentials | The Credentials to use when authenticating with JNDI (java.naming.security.credentials). Чувствительный параметр: true |
| JMS Connection Factory Implementation Class | Полное имя класса реализации JMS ConnectionFactory (например, org.apache.activemq.ActiveMQConnectionFactory). Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| JMS Client Libraries | Путь к каталогу с дополнительными ресурсами (например, JAR-файлами, файлами конфигурации и т. д.), которые необходимо добавить в путь к классам (определяется как список значений, разделённых запятыми). Т акие ресурсы обычно представляют собой целевые клиентские библиотеки JMS для реализации ConnectionFactory.This property expects a comma-separated list of resources. Each of the resources may be of any of the following types: directory, URL, file. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| JMS Broker URI | URI, указывающий на сетевое расположение брокера сообщений JMS. Пример для ActiveMQ: 'tcp://myhost:61616'. Примеры для IBM MQ: 'myhost(1414)' и 'myhost01(1414),myhost02(1414)'. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| JMS SSL Context Service | Служба контекста SSL, используемая для предоставления информации о сертификате клиента для подключений TLS/SSL. |
Взаимосвязи
- success: Все файлы Flow, отправляемые в пункт назначения JMS, направляются в эту связь.
- failure: Все файлы Flow, которые не могут быть отправлены в пункт назначения JMS, направляются в эту связь.