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, направляются в эту связь.