ConsumeJMS 2025.5.31.15¶
Bundle¶
org.apache.nifi | nifi-jms-processors-nar
Description¶
Consomme un message JMS du type BytesMessage, TextMessage, ObjectMessage, MapMessage ou StreamMessage, transforme son contenu en FlowFile et le transmet à la relation « success ». Les attributs JMS tels que les en-têtes et les propriétés seront copiés en tant qu’attributs du FlowFile. Les MapMessages seront transformés en objets JSON, puis en tableaux d’octets. Pour les autres types, le contenu brut sous forme de tableau d’octets sera transféré dans le FlowFile.
Exigences en matière d’entrées¶
FORBIDDEN
Prend en charge les propriétés dynamiques sensibles¶
false
Propriétés¶
Propriété |
Description |
|---|---|
Acknowledgement Mode |
Le mode d’acquittement JMS. Le mode Auto Acknowledge peut entraîner la perte de messages lors du redémarrage de NiFi, mais peut offrir de meilleures performances que le mode Client Acknowledge. |
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 » |
Durable subscription |
Si la destination est un « Topic » et si elle est présente, le consommateur sera défini comme durable. Voir https://jakarta.ee/specifications/platform/9/apidocs/jakarta/jms/session#createDurableConsumer-jakarta.jms.Topic-java.lang.String- |
Error Queue Name |
Nom d’une file d’attente JMS dans laquelle - si cette option est configurée - les messages non traités seront routés. Généralement fourni par l’administrateur (par exemple, « queue://myErrorQueue » ou « myErrorQueue »). Applicable uniquement si le paramètre « Destination Type » est défini sur « QUEUE » |
Maximum Batch Size |
Nombre maximal de messages à publier ou à consommer à chaque invocation du processeur. |
Message Selector |
Le sélecteur de messages JMS utilisé pour filtrer les messages que le processeur recevra |
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. |
Shared subscription |
Si la destination est un « Topic », cette propriété crée un abonnement partagé. Voir https://jakarta.ee/specifications/platform/9/apidocs/jakarta/jms/session#createSharedConsumer-jakarta.jms.Topic-java.lang.String- |
Subscription Name |
Le nom de l’abonnement à utiliser si la destination est un « Topic » et si elle est partagée ou durable. |
Expiration |
Temps d’attente pour consommer un message du broker distant avant d’abandonner. |
Nom d’utilisateur |
Nom d’utilisateur utilisé pour l’authentification et l’autorisation. |
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). |
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). |
output-strategy |
Le format utilisé pour convertir le message JMS en un enregistrement FlowFile. |
record-reader |
Le Record Reader à utiliser pour analyser les messages JMS reçus et les convertir en enregistrements. |
record-writer |
Le Record Writer à utiliser pour sérialiser les enregistrements avant de les écrire dans un FlowFile. |
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 |
|---|---|
parse.failure |
Si un message ne peut pas être analysé par le Record Reader configuré, le contenu du message sera routé vers cette relation sous la forme d’un FlowFile individuel. |
success |
Tous les FlowFiles reçus de la destination JMS sont routés vers cette relation |
Écrit les attributs¶
Nom |
Description |
|---|---|
jms_deliveryMode |
Le paramètre JMSDeliveryMode extrait de l’en-tête du message. |
jms_expiration |
Le paramètre JMSExpiration extrait de l’en-tête du message. |
jms_priority |
Le paramètre JMSPriority extrait de l’en-tête du message. |
jms_redelivered |
Le paramètre JMSRedelivered extrait de l’en-tête du message. |
jms_timestamp |
Le paramètre JMSTimestamp extrait de l’en-tête du message. |
jms_correlationId |
Le paramètre JMSCorrelationID extrait de l’en-tête du message. |
jms_messageId |
Le paramètre JMSMessageID extrait de l’en-tête du message. |
jms_type |
Le paramètre JMSType extrait de l’en-tête du message. |
jms_replyTo |
Le paramètre JMSReplyTo extrait de l’en-tête du message. |
jms_destination |
Le paramètre JMSDestination extrait de l’en-tête du message. |
jms.messagetype |
Le type de message JMS peut être TextMessage, BytesMessage, ObjectMessage, MapMessage ou StreamMessage. |
other attributes |
Chaque propriété de message est inscrite dans un attribut. |