PublishJMS 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-jms-processors-nar
Description¶
Crée un message JMS à partir du contenu d’un FlowFile et l’envoie à une destination JMS (file d’attente ou sujet) en tant que BytesMessage ou TextMessage JMS. Les attributs du FlowFile seront ajoutés en tant qu’en-têtes JMS et/ou propriétés au message sortant JMS.
Exigences en matière d’entrées¶
REQUIRED
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Connection Client ID |
L’identifiant du client à paramétrer sur la connexion, s’il est défini. Ce paramètre est obligatoire pour les consommateurs durables non partagés, et facultatif pour tous les autres. En règle générale, son paramétrage n’est pas souhaitable pour les consommateurs partagés. Pour plus de détails, veuillez consulter les spécifications de JMS |
Connection Factory Service |
Le Controller Service qui est utilisé pour obtenir la fabrique de connexion. Les propriétés « JNDI * » ou « JMS * » peuvent également être utilisées pour configurer la fabrique de connexion. |
Destination Name |
Le nom de la destination JMS. Généralement fourni par l’administrateur (par exemple, « topic://myTopic » ou « myTopic »). |
Destination Type |
Le type de la destination JMS. Les valeurs possibles sont « QUEUE » ou « TOPIC ». Généralement fourni par l’administrateur. La valeur par défaut est « QUEUE » |
Maximum Batch Size |
Nombre maximal de messages à publier ou à consommer à chaque invocation du processeur. |
Mot de passe |
Mot de passe utilisé pour l’authentification et l’autorisation. |
Service contextuel SSL |
Le service de contexte SSL utilisé pour fournir des informations sur les certificats des clients pour les connexions TLS/SSL. |
Nom d’utilisateur |
Nom d’utilisateur utilisé pour l’authentification et l’autorisation. |
allow-illegal-chars-in-jms-header-names |
Indique si les caractères illégaux dans les noms d’en-tête doivent être envoyés au courtier JMS. Généralement des traits d’union et des points. |
attributes-to-send-as-jms-headers-regex |
Spécifie l’expression régulière qui détermine les noms des attributs de FlowFile qui doivent être envoyés en tant qu’en-têtes JMS |
broker |
URI pointant vers l’emplacement réseau du broker de messages JMS. Exemple pour ActiveMQ : « tcp://myhost:61616 ». Exemples pour IBM MQ : « myhost(1414) » et « myhost01(1414),myhost02(1414) ». |
cf |
Le nom complet de la classe d’implémentation JMS ConnectionFactory (par exemple, org.apache.activemq.ActiveMQConnectionFactory). |
cflib |
Chemin d’accès au répertoire contenant des ressources supplémentaires (par exemple, fichiers JAR, fichiers de configuration, etc.) à ajouter au classpath (défini comme une liste de valeurs séparées par des virgules). Ces ressources correspondent généralement aux bibliothèques client JMS cibles pour l’implémentation de la ConnectionFactory. |
character-set |
Le nom du jeu de caractères à utiliser pour construire ou interpréter des TextMessages |
connexion.factory.name |
Le nom de l’objet JNDI à rechercher pour la fabrique de connexion. |
java.naming.factory.initial |
Le nom entièrement qualifié de la classe JNDI Initial Context Factory (java.naming.factory.initial). |
java.naming.provider.url |
L’URL du fournisseur JNDI à utiliser comme valeur pour java.naming.provider.url. Reportez-vous à la documentation pour plus de détails sur les schémas d’URL autorisés. |
java.naming.security.credentials |
Les identifiants à utiliser lors de l’authentification auprès de JNDI (java.naming.security.credentials). |
java.naming.security.principal |
Le principal à utiliser lors de l’authentification auprès de JNDI (java.naming.security.principal). |
message-body-type |
Le type de corps de message JMS à construire. |
naming.factory.libraries |
Spécifie les fichiers et/ou répertoires jar à ajouter à ClassPath afin de charger les bibliothèques client JNDI/JMS. Il s’agit d’une liste de fichiers, de répertoires et/ou d’URL séparés par des virgules. Si un répertoire est indiqué, tous les fichiers de ce répertoire seront inclus, mais les sous-répertoires ne le seront pas (cette méthode n’est pas récursive). |
record-reader |
Le Record Reader à utiliser pour analyser le FlowFile entrant en enregistrements. |
record-writer |
Le Record Writer à utiliser pour sérialiser les enregistrements avant de les publier sous la forme d’un message JMS. |
Restrictions¶
Autorisation requise |
Explication |
|---|---|
reference remote resources |
L’emplacement de la bibliothèque cliente permet de faire référence à des ressources via HTTP |
Relations¶
Nom |
Description |
|---|---|
failure |
Tous les FlowFiles qui ne peuvent pas être envoyés à la destination JMS sont routés vers cette relation. |
success |
Tous les FlowFiles qui sont envoyés à la destination JMS sont routés vers cette relation. |