Propriétés du tMomInput Standard

Use existing connection

Cochez cette case et sélectionnez le composant de connexion adéquat dans la liste Component list pour réutiliser les paramètres d'une connexion que vous avez déjà définie.

Notez que lorsqu'un Job contient un Job parent et un Job enfant, la liste Component List présente uniquement les composants de connexion du Job du même niveau.

Keep Listening

Cochez cette case pour consulter en continu le serveur MOM pour récupérer les nouveaux messages.

Cette case n'est pas disponible lorsque vous sélectionnez ActiveMQ ou WebSphere MQ dans la liste MQ server et que la case receive number of messages est cochée.

Sleeping time (in sec)

Saisissez en secondes l'intervalle de temps durant lequel le message suivant doit être reçu.

receive number of messages

Cochez cette case pour configurer le nombre maximal de messages pouvant être reçus.

Cette case est disponible lorsque vous sélectionnez ActiveMQ ou WebSphere MQ dans la liste MQ server et que la case Keep Listening est décochée.

maximum messages

Saisissez le nombre maximal de messages pouvant être reçus.

Ce champ est disponible uniquement lorsque vous cochez la case receive number of messages.

Timeout for receiver

Cochez cette case et spécifiez l'intervalle de temps avant suspension de la réception, dans le champ Sleeping time (in sec).

Cette case est disponible uniquement lorsque la case receive number of messages est cochée.

Failover

Cochez cette case pour utiliser le transport pour le failover ActiveMQ. Pour plus d'informations concernant le transport relatif au failover, consultez Failover Transport Reference (uniquement en anglais) (en anglais).

Cette case est disponible uniquement lorsque vous sélectionnez ActiveMQ dans la liste MQ Server et que la case Static Discovery est décochée.

Static Discovery

Cochez cette case pour utiliser le mécanisme de transport statique ActiveMQ. Pour plus d'informations concernant le transport statique, consultez Static Transport Reference (uniquement en anglais) (en anglais).

Cette case est disponible uniquement lorsque vous sélectionnez ActiveMQ dans la liste MQ Server et que la case Static Discovery est décochée.

URI parameters

Saisissez les paramètres de l'URI.

Ce champ est disponible uniquement lorsque la case Failover ou Static Discovery est cochée.

MQ Server

Sélectionnez dans la liste le type de serveur MQ auquel se connecter : ActiveMQ, JBoss Messaging ou WebSphere MQ. En fonction du serveur sélectionné, les paramètres requis varient légèrement.

Use SSL Transport

Cochez cette case pour utiliser le transport ActiveMQ SSL. Pour plus d'informations concernant le transport SSL, consultez SSL Transport Reference (uniquement en anglais) (en anglais).

Cette case est disponible uniquement lorsque vous sélectionnez ActiveMQ dans la liste MQ server.

Host

Renseignez le nom de l'hôte ou l'adresse IP du serveur MQ

Port

Saisissez le numéro du port d'écoute du serveur MQ.

Username et Password

Saisissez vos informations d'authentification de l'utilisateur ou de l'utilisatrice.

Pour saisir le mot de passe, cliquez sur le bouton [...] à côté du champ Password, puis, dans la boîte de dialogue qui s'ouvre, saisissez le mot de passe entre guillemets doubles et cliquez sur OK afin de sauvegarder les paramètres.

Channel

Spécifiez le nom du canal dans lequel la connexion est établie. La valeur par défaut est DC.SVRCONN.

Ce champ est disponible uniquement lorsque vous sélectionnez WebSphere MQ dans la liste MQ server.

Message From

Saisissez la source du message, telle qu'attendue par le serveur. Celle-ci peut être composée du type et du nom de la source, par exemple : queue/A ou topic/testtopic.

Notez que ce champ est sensible à la casse.

Ce champ est disponible uniquement lorsque vous sélectionnez ActiveMQ ou JBoss Messaging dans la liste MQ Server.)

Message Type

Sélectionnez le type de message : topic ou queue.

Ce champ est disponible uniquement lorsque vous sélectionnez ActiveMQ ou JBoss Messaging dans la liste MQ Server.)

Message Body Type

Sélectionnez le type de message : Text Message, Bytes Message ou Map Message.

Schema et Edit Schema

Un schéma est une description de lignes, il définit le nombre de champs qui sont traités et passés au composant suivant.

Dans le cadre de l'utilisation du tMomInput, le schéma est composé de deux colonnes : From et Message, dont le nom est en lecture seule.

QueueManager

Spécifiez le nom du gestionnaire de file auquel la connexion est établie.

Ce champ est disponible uniquement lorsque vous sélectionnez WebSphere MQ dans la liste MQ server.

MessageQueue

Saisissez le nom de la file d'attente des messages dans laquelle les applications de mise en file d'attente mettent les messages.

Ce champ est disponible uniquement lorsque vous sélectionnez WebSphere MQ dans la liste MQ server.

Is using message id to fetch

Cochez cette case pour récupérer les messages selon leur ID.

Cette case est disponible uniquement lorsque vous sélectionnez Text Message ou Bytes Message dans la liste Message Body Type.

Commit (delete message after read from the queue)

Cochez cette case afin de forcer le commit après lecture de chaque message dans la file d'attente.

Ce champ est disponible uniquement lorsque vous sélectionnez WebSphere MQ dans la liste MQ server et que la case Browse Message est décochée dans la vue Advanced settings.

Backout messages to input queue

Cochez cette case pour remettre dans la file le message après l'avoir lu.

Cette case et la case Browse Message de la vue Advanced settings vous permettent de lire des messages depuis la file sans les détruire. Pour plus d'informations, consultez https://publib.boulder.ibm.com/iseries/v5r2/ic2924/books/csqzaw07.pdf (uniquement en anglais).

Cette case est disponible lorsque vous sélectionnez WebSphere MQ dans la liste MQ server et que les cases Keep Listening, Commit (delete message after read from the queue) et Browse message sont décochées.

Backout messages to backout queue (when backoutCount of message reach the threshold value)

Cochez cette case pour effectuer un backout sur les messages dans la file de backout définie dans le gestionnaire Websphere MQ lorsque le nombre de backout atteint le seuil configuré, qui est une propriété de la file du serveur Websphere MQ.

Cette case est disponible lorsque vous sélectionnez WebSphere MQ dans la liste MQ server et que les cases Keep Listening, Commit (delete message after read from the queue) et Browse message sont décochées.

Set Transacted

Cochez cette case pour utiliser les transactions dans la session. Pour plus d'informations concernant ce paramètre, consultez https://publib.boulder.ibm.com/iseries/v5r2/ic2924/books/csqzaw07.pdf (uniquement en anglais) (en anglais).

Cette case est disponible uniquement lorsque vous sélectionnez ActiveMQ dans la liste MQ server.

start server

Cochez cette case pour forcer le démarrage du serveur ActiveMQ.

Cette case est disponible uniquement lorsque vous sélectionnez ActiveMQ dans la liste MQ server.

Additional options

Définissez dans la table les options de transport supplémentaires. Cette table est disponible uniquement si vous avez coché la case Failover ou Static Discovery dans la vue Basic settings.

• Option name : nom de l'option.

• Option value : valeur de l'option.

Par exemple, saisissez maxReconnectAttempts dans le champ Option name, puis 0 dans le champ Option value afin qu'aucune tentative ne soit effectuée pour récupérer la connexion lorsqu'aucun serveur n'est disponible.

Pour plus d'informations concernant les options de transport liées au failover, consultez Failover Transport Reference (uniquement en anglais) (en anglais).

Pour plus d'informations concernant les options de transport statique, consultez Static Transport Reference (uniquement en anglais) (en anglais).

Acknowledgement Mode

Sélectionnez dans la liste un mode d'accusé de réception pour indiquer que le client a bien reçu le(s) message(s) :

Auto Acknowledge : avec ce mode d'accusé de réception, l'acquittement se fait automatiquement, le client reçoit l'accusé de réception à la réception du message, qu'il soit traité ou non par l'application.

Client Acknowledge : avec ce mode d'accusé de réception, le client accuse réception d'un message en appelant la méthode d'accusé réception du message.

Dups OK Acknowledge : ce mode d'accusé de réception donne à la session l'instruction d'accuser réception mollement de la livraison des messages.

Get Jms Header

Get Jms Properties

Cochez cette case pour recevoir les propriétés JMS mappées dans les champs MQMD. Lorsque cette case est cochée, vous pouvez spécifier le nom et le type de la propriété, et le nom de la colonne de référence dans la (les) ligne(s) ajoutée(s) en cliquant sur le bouton [+] sous la table Parameters. Pour plus d'informations concernant l'utilisation des propriétés JMS, consultez le https://publib.boulder.ibm.com/iseries/v5r2/ic2924/books/csqzaw07.pdf (uniquement en anglais) (en anglais).

Disponible lorsque vous sélectionnez ActiveMQ ou JBoss Messaging dans la liste MQ Server.

Browse message

Cochez cette case afin de désactiver les options Commit (delete message after read from the queue) et Backout messages to input queue dans la vue Basic settings et d'ouvrir la file pour parcourir les messages.

Get MQMD Fields

Cochez cette case pour définir un ou plusieurs Message Descriptor(s) en ajoutant de nouveaux champs pour MQMD (Message queuing message descriptor) dans le tableau Parameter :

Field Name : sélectionnez un ou plusieurs descripteur(s) de messages dans la liste afin de récupérer les informations de l'en-tête du message.

Reference Column Name : informations d'en-tête et de propriétés du message.

Pour plus d'informations, consultez http://publib.boulder.ibm.com/infocenter/wmqv7/v7r0m0/index.jsp?topic=%2Fcom.ibm.mq.csqzak.doc%2Ffr13040_.htm/ (uniquement en anglais) (en anglais).

Disponible lorsque vous sélectionnez Websphere MQ dans la liste MQ Server.

Include Header

Cochez cette case pour définir l'en-tête du message :

MQRFH2 fixed Portion : cochez cette case et cliquez sur le bouton [+] pour ajouter une ou plusieurs ligne(s) pour spécifier la Version, l'encodage (Encoding), le Format, les Flags et les valeurs NameValueCCSID et CodeCharSetId pour la portion fixe de l'en-tête MQRFH2.

MCD folder : cochez cette case et cliquez sur le bouton [+] pour ajouter une ou plusieurs ligne(s) pour spécifier le nom des champs et de la colonne de référence des propriétés décrivant le format du message.

JMS folder : cochez cette case et cliquez sur le bouton [+] pour ajouter une ou plusieurs ligne(s) pour spécifier le nom des champs et de la colonne de référence pour le transport des champs d'en-têtes JMS et des propriétés JMSX.

USR folder : cochez cette case et cliquez sur le bouton [+] pour ajouter une ou plusieurs ligne(s) pour spécifier le nom des champs et de la colonne de référence pour le transport des propriétés définies par l'application associées au message.

Pour plus d'informations concernant les en-têtes MQRFH2, consultez http://publib.boulder.ibm.com/infocenter/wmbhelp/v6r1m0/index.jsp?topic=%2Fcom.ibm.etools.mft.doc%2Faq06920_.htm (uniquement en anglais) (en anglais).

Cette case est disponible lorsque l'option WebSphere MQ est sélectionnée dans la liste MQ Server.

Set Cipher Suite

Cochez cette case pour activer la liste Cipher Suite dans laquelle vous pouvez spécifier la Cipher Suite à utiliser avec le SSL WebSphere.

Pour plus d'informations concernant les suites cryptographiques, consultez CipherSpecs and their equivalent CipherSuites supported by IBM WebSphere MQ (uniquement en anglais) (en anglais).

Cette case est disponible lorsque l'option WebSphere MQ est sélectionnée dans la liste MQ Server.

Custom Cipher Suite

Cochez cette case pour collecter les données de log au niveau du composant.

IBM Cipher Mappings : utilise IBM Java Cipher Suite pour les mappings IBM MQ Cipher Spec.

Oracle Cipher Mappings : utilise Oracle Cipher Suite pour les mappings IBM MQ Cipher Spec.

tStatCatcher Statistics

Cochez cette case pour collecter les métadonnées de traitement du Job au niveau du Job ainsi qu'au niveau de chaque composant.

Variables globales

ERROR_MESSAGE : message d'erreur généré par le composant lorsqu'une erreur survient. Cette variable est une variable After et retourne une chaîne de caractères. Cette variable fonctionne uniquement si la case Die on error est décochée, lorsque le composant contient cette case.

NB_LINE : nombre de lignes lues par un composant d'entrée ou passées à un composant de sortie. Cette variable est une variable After et retourne un entier.

Une variable Flow fonctionne durant l'exécution d'un composant.

Pour renseigner un champ ou une expression à l'aide d'une variable, appuyez sur les touches Ctrl+Espace pour accéder à la liste des variables. À partir de cette liste, vous pouvez choisir la variable que vous souhaitez utiliser.

Pour plus d'informations concernant les variables, consultez le Guide d'utilisation du Studio Talend.

Règle d'utilisation

Ce composant est généralement utilisé en tant que composant de début. Il requiert un composant de sortie.

Dynamic settings

Cliquez sur le bouton [+] pour ajouter une ligne à la table. Dans le champ Code, saisissez une variable de contexte afin de sélectionner dynamiquement votre connexion HDFS parmi celles prévues dans votre Job.

La table Dynamic settings est disponible uniquement lorsque la case Use an existing connection est cochée dans la vue Basic settings. Lorsqu'un paramètre dynamique est configuré, la liste Component List de la vue Basic settings devient inutilisable.

Pour des exemples d'utilisation de paramètres dynamiques, consultez Lire des données dans des bases de données MySQL à l'aide de connexions dynamiques basées sur les variables de contexte et Lire des données à partir de différentes bases de données MySQL à l'aide de paramètres de connexion chargés dynamiquement. Pour plus d'informations concernant les paramètres dynamiques (Dynamic settings) et les variables de contexte, consultez le Guide d'utilisation du Studio Talend.

Limitation

Assurez-vous que le serveur Websphere, JBoss ou ActiveMQ correspondant est lancé.

Ce composant requiert l'installation des fichiers .jar associés.