Scenario 1: Asynchronous communication via a MOM server - 6.3

Talend Open Studio for Big Data Components Reference Guide

EnrichVersion
6.3
EnrichProdName
Talend Open Studio for Big Data
task
Data Governance
Data Quality and Preparation
Design and Development
EnrichPlatform
Talend Studio

This scenario is made of two Jobs. The first Job posts messages on a JBoss server queue and the second Job fetches the message from the server.

Configuring and executing the first Job

In the first Job, a string message is created using a tRowGenerator and put on a JBoss server using a tMomOutput. An intermediary tLogRow component displays the flow being passed.

  1. Drop the three components required for the first Job from the Palette onto the design workspace and right-click to connect them using a Main row link.

  2. Double-click on tRowGenerator to set the schema to be randomly generated.

  3. Set just one column called message. This is the message to be put on the MOM queue.

  4. This column is of String type and is nullable. To produce the data, use a preset function which concatenates randomly chosen ascii characters to form a 6-char string. This function is getAsciiRandomString. (Java version). Click the Preview button to view a random sample of data generated.

  5. Set the Number of rows to be generated to 10.

    Click OK to validate.

  6. The tLogRow is only used to display a intermediary state of the data to be handled. In this example, it doesn't require any specific configuration.

  7. Then select the tMomOutput component.

  8. In this case, the MQ server to be used is JBoss.

    In the Host and Port fields, fill in the relevant connection information.

  9. Select the Message type from the list. The message can be of Queue or Topic type. In this example, select the Queue type from the list.

  10. In the To field, type in the message source information strictly respecting the syntax expected by the server. This should match the Message Type you selected, such as: queue/A.

    Note

    The message name is case-sensitive, therefore queue/A and Queue/A are different.

  11. Then click Sync Columns to pass on the schema from the preceding component. The schema being read-only, it cannot be changed. The data posted onto the MQ comes from the first schema column encountered.

  12. Press F6 to execute the Job and view the data flow being passed on in the console, thanks to the tLogRow component.

Configuring and executing the second Job

Then set the second Job in order to fetch the queuing messages from the MOM server.

  1. Drop the tMomInput component and a tLogRow from the Palette to the design workspace.

  2. Select the tMomInput to set the parameters.

  3. Select the MQ server from the list. In this example, a JBoss messaging server is used.

  4. Set the server Host and Port information.

  5. Set the Message From and the Message Type to match the source and type expected by the messaging server.

  6. The Schema is read-only and is made of two columns: From and Message.

  7. Select the Keep listening check box and set the verification frequency to 5 seconds.

    Note

    When using the Keep Listening option, you'll need to kill the Job to end it.

  8. No need to change any default setting from the tLogRow.

  9. Save the Job and run it (when launching for the first time or if you killed it on a previous run).

    The messages fetched on the server are displayed on the console.