ConsumeJMS
Описание
Потребляет JMS-сообщение типа BytesMessage, TextMessage, ObjectMessage, MapMessage или StreamMessage, преобразуя его содержимое в файл потока и переводя его в отношение «success». Атрибуты JMS, такие как заголовки и свойства, будут скопированы как атрибуты файла потока. MapMessages будут преобразованы в JSON, а затем в массивы байтов. Содержимое остальных типов будет передано в файл потока в виде массива байтов.
Теги
jms, get, message, receive, consume
Свойства
| Название | Описание |
|---|---|
| Connection Factory Service | Служба контроллера, используемая для получения фабрики подключений. В качестве альтернативы для настройки фабрики подключений можно использовать свойства 'JNDI *' или 'JMS *'. |
| Destination Name | Имя назначения JMS. Обычно указывается администратором (например, 'topic://myTopic' или 'myTopic'). Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Destination Type | Тип назн ачения JMS. Может быть одним из "QUEUE" или "TOPIC". Обычно указывается администратором. По умолчанию используется "QUEUE" |
| Message Selector | Селектор сообщений JMS для фильтрации сообщений, которые получит процессор Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| User Name | Имя пользователя, используемое для аутентификации и авторизации. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Password | Пароль, используемый для аутентификации и авторизации. Чувствительный параметр: true |
| Connection Client ID | Идентификатор клиента, который должен быть установлен при подключении, если он установлен. Для долговременных пользователей без общего доступа это обязательно, для всех остальных это необязательно, обычно для пользователей с общим доступом это нежелательно устанавливать. Пожалуйста, смотрите спецификацию JMS для получения более подробной информации Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Character Set | Название набора символов, используемого для создания или интерпретации текстовых сообщений. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Acknowledgement Mode | Режим подтверждения JMS. Использование автоматического подтверждения может привести к потере сообщений при перезапуске NiFi, но может обеспечить более высокую производительность, чем подтверждение клиентом. |
| Durable Subscription | Если местом назначения является тема, то сделайте ее долговременной. @see https://jakarta.ee/specifications/platform/9/apidocs/jakarta/jms/session#createDurableConsumer-jakarta.jms.Topic-java.lang.String- Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Shared Subscription | Если в качестве назначения указана тема, то сделайте ее общей для потребителей. @see https://jakarta.ee/specifications/platform/9/apidocs/jakarta/jms/session#createSharedConsumer-jakarta.jms.Topic-java.lang.String- П оддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Subscription Name | Имя подписки, используемой в случае, если местом назначения является тема и она является общей или долговременной. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Timeout | Время ожидания получения сообщения от удаленного брокера, прежде чем отказаться от его получения. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Error Queue Name | Имя очереди JMS, в которую — если задано — будут направляться необработанные сообщения. Обычно задается администратором (например, «очередь://myErrorQueue» или «myErrorQueue»).Применимо только в том случае, если для «типа назначения» установлено значение «очередь» Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Record Reader | Средство чтения записей, используемое для преобразования полученных сообщений JMS в записи. |
| Record Writer | Средство записи записей для се риализации записей перед их записью в файл Flow.This Property is only considered if the [Record Reader] Property has a value specified. |
| Output Strategy | Формат, используемый для вывода сообщения JMS в запись FlowFile.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: Все файлы потока, полученные из пункта назначения JMS, направляются в это отношение
- parse.failure: Если сообщение не может быть проанализировано с помощью настроенного считывателя записей, содержимое сообщения будет направлено в это отношение как отдельный файл потока.