Configurer les composants - Cloud - 8.0

Wiretap (Mediation)
Version
Cloud
8.0
Language
Français
Product
Talend Data Fabric
Talend Data Services Platform
Talend ESB
Talend MDM Platform
Talend Real-Time Big Data Platform
Module
Studio Talend
Content
Création et développement > Systèmes tiers > Composants Routing (Médiation) > Composants Wiretap (Médiation)
Gouvernance de données > Systèmes tiers > Composants Routing (Médiation) > Composants Wiretap (Médiation)
Qualité et préparation de données > Systèmes tiers > Composants Routing (Médiation) > Composants Wiretap (Médiation)
Last publication date
2024-02-21

Procédure

  1. Double-cliquez sur le composant cFile nommé Source pour afficher sa vue Basic settings dans l'onglet Component.
  2. Dans le champ Path, saisissez le chemin d'accès au fichier d'entrée ou parcourez votre système jusqu'à celui-ci. Dans ce scénario, le fichier spécifié dans le chemin d'accès est Hello.txt et contient la phrase Hello World!. Laissez les autres champs tels qu'ils sont.
  3. Double-cliquez sur le composant cWireTap pour afficher sa vue Basic settings dans l'onglet Component.
  4. Saisissez "direct:a" dans le champ URI pour router le message écouté vers cet endpoint.
    Cochez la case Populate new exchange, sélectionnez Processor dans la zone Populate Type puis saisissez le code suivant dans le champ Code pour afficher le nom de fichier du message écouté ainsi que son contenu dans la console :
    System.out.println("\nMessage wiretapped: "+
exchange.getIn().getHeader("CamelFileName"));
System.out.println("Message content: "+
exchange.getIn().getBody(String.class)+"\n");
  5. Double-cliquez sur le cJavaDSLProcessor pour afficher sa vue Basic settings dans l'onglet Component.
  6. Dans le champ Code, saisissez le code Java .to("direct:b") pour définir l'URI de l'endpoint vers lequel router le message original.
  7. Double-cliquez sur le composant cMessagingEndpoint nommé Endpoint_a pour afficher sa vue Basic settings dans l'onglet Component. Saisissez "direct:a" dans le champ URI pour récupérer le message routé vers cet endpoint.
    Répétez cette opération pour configurer l'URI de l'endpoint pour Endpoint_b.
  8. Double-cliquez sur le composant cProcessor nommé Monitor_a pour afficher sa vue Basic settings dans l'onglet Component. Saisissez le code suivant dans le champ Code pour afficher le nom de fichier du message routé vers l'Endpoint_a. 
    System.out.println("Message on endpoint a: "+
exchange.getIn().getHeader("CamelFileName"));
    Configurez l'autre composant cProcessor de la même manière afin d'afficher le nom de fichier du message routé vers l'Endpoint_b.
  9. Appuyez sur les touches Ctrl+S pour sauvegarder votre Route.