FME Flow:2025.1
Message JMS
L'action externe Message JMS reçoit les messages et les relaie vers des courtiers de messages compatibles Java Message System (JMS), tels qu'IBM WebSphere MQ.
L'action externe du message JMS possède deux ports de sortie. Le port du succès (✔) peut envoyer un message si le courtier de messages est notifié avec succès. Le port d'échec (x) peut envoyer un message si la notification échoue.
Configuration d'un courtier de messages JMS avecFME Flow
Avant de configurer une action externe de message JMS, vous devez configurer un courtier JMS avec lequel travailler.FME Flow. Les étapes dépendent du courtier que vous utilisez et sont expliquées dans la section suivante :
Paramètres
- Type de fournisseur ou contexte: Le courtier de messages auquel se connecter, ou la fabrique de contexte initiale si le courtier n'est pas répertorié.
- URL du fournisseur: L'URL du répertoire contenant les détails de connexion pour le fournisseur JMS.
- Propriétés supplémentaires du fournisseur:Toutes les propriétés supplémentaires spécifiques au fournisseur, sous la formeclé=valeur. Par exemple,randomize=false. Spécifiez plusieurs paires sur des lignes séparées.
- Usine de connexion: Le nom de l'objet de fabrique de connexion.
- Nom d'utilisateur:Un nom d'utilisateur d'authentification.
- Mot de passe:Un mot de passe d'authentification.
- Destination(s): Le nom du ou des objets de destination. Ceux-ci correspondent à des files d'attente et/ou à des sujets. Plusieurs destinations peuvent être spécifiées, séparées par une virgule.
- Utiliser la livraison persistante: SiOui, les messages sont stockés par le courtier JMS jusqu'à ce que le message soit livré à une destination et peuvent être récupérés en cas de redémarrage du courtier. SiNon, les messages peuvent être perdus en cas de redémarrage du courtier pendant la livraison. La livraison persistante est plus lente que la livraison non persistante, en particulier lors de l'envoi de gros volumes de messages.
- Modèle de contenu de notification: Le corps du message.
À propos du modèle de contenu de notificationLe modèle de contenu de notification utilise les mots-clés suivants dans la notification entrante :
{
"emplacement": "<emplacement>"
"subscriber_content": "message_personnalisé"
}
Si le"subscriber_content" le mot-clé est présent, il remplace le modèle de contenu de notification.
Par exemple, considérons le modèle de contenu de notification suivant :
Bonjour, {Lieu}
Si la notification entrante contient les éléments suivants :
{
"emplacement" : "monde"
}
L'abonné JMS envoie le message suivant :
"Bonjour le monde"
Si la notification entrante contient les éléments suivants :
{
"emplacement" : "monde"
"subscriber_content": "Mon message personnalisé"
}
L'abonné JMS envoie le message suivant :
"Mon message personnalisé"
Dans la plupart des cas, ce champ n'est pas obligatoire. Les courtiers JMS testés par Safe, notamment Apache ActiveMQ, IBM Websphere MQ et Oracle WebLogic JMS, ne nécessitent aucune propriété supplémentaire pour établir une connexion.
Exemples de configurations
Exemple de configuration d'Apache ActiveMQ
| Chemin de classe Java |
Aucun changement requis. (Les bibliothèques Apache ActiveMQ 5.6.0 sont fournies avecFME Flow.) |
| Type de fournisseur ou contexte | ACTIVMQ |
| URL du fournisseur | tcp://serveur:61616 |
| Propriétés supplémentaires du fournisseur | -- |
| Usine de connexion | ConnectionFactory |
| Nom d'utilisateur |
-- |
| Mot de passe |
-- |
| Destination(s) | dynamicQueues/MaFileD'Attente |
Exemple de configuration d'IBM WebSphere 7
| Chemin de classe Java | ... -FMESERVER_CLASSPATH « ...;C:/Program Files (x86)/IBM/WebSphere MQ/java/lib/* » ... |
| Type de fournisseur ou contexte | WEBSPHERE70 |
| URL du fournisseur | fichier:/C:/jndi/ |
| Propriétés supplémentaires du fournisseur | -- |
| Usine de connexion | cf1 |
| Nom d'utilisateur | administrateur |
| Mot de passe | administrateur |
| Destination(s) | q1,t1 |
Exemple de configuration d'Oracle Weblogic
| Type de fournisseur ou contexte | weblogic.jndi.WLInitialContextFactory |
| URL du fournisseur | t3://bq-w2008:7001 |
| Propriétés supplémentaires du fournisseur | -- |
| Usine de connexion | jms/TestConnectionFactory |
| Nom d'utilisateur |
-- |
| Mot de passe |
-- |
| Destination(s) | jms/TestJMSQueue |
Attributs de sortie
Voir aussi
| Attribut | Description |
|---|---|
| temps | Heure de l'événement |
| source | Type d'événement |
| type d'erreur |
(Port d'échec uniquement) Type d'erreur :
|
| message d'erreur | (Port d'échec uniquement) Message d'erreur |
Réessayer
- Réessayer en cas d'échec: Si cette option est cochée, l'automatisation tente d'exécuter à nouveau l'action si la tentative initiale aboutit à un échec de connexion à la ressource externe spécifiée pour la remise du message. La manière dont ces nouvelles tentatives sont effectuées est basée sur les paramètres restants.
- Utiliser les paramètres de nouvelle tentative personnalisés: Si cette case est cochée, les paramètres de nouvelle tentative restants sont configurables. Si cette case n'est pas cochée, ils sont définis surFME Flow valeurs par défaut.
- Nombre de tentatives: Nombre maximal de tentatives, si l'action continue d'échouer.
- Attendre entre les tentatives:Temps d'attente entre les tentatives. En collaboration avecMultiplicateur de recul (ci-dessous), la valeur spécifiée est le temps d'attente pour la première tentative.
- Multiplicateur de recul: Facteur par lequel augmenterAttendre entre les tentatives lors de tentatives successives. Par exemple, une valeur de2.0 double le temps d'attente pour la prochaine tentative.
- Facteur de randomisation: Pourcentage selon lequel introduire du caractère aléatoire dansAttendre entre les tentatives. Par exemple, siAttendre entre les tentatives est100 secondes, etFacteur de randomisation est25, le temps d'attente pour chaque nouvelle tentative est sélectionné aléatoirement entre 75 et 125 secondes.
- Délai d'attente maximal entre les tentatives: Temps d'attente maximal entre les tentatives. En collaboration avecMultiplicateur de recul, la valeur spécifiée est la limite supérieure du temps d'attente.