Configuring and executing the first Job - 7.3

MOM

Version
7.3
Language
English
Product
Talend Big Data
Talend Big Data Platform
Talend Data Fabric
Talend Data Integration
Talend Data Management Platform
Talend Data Services Platform
Talend ESB
Talend MDM Platform
Talend Real-Time Big Data Platform
Module
Talend Studio
Content
Data Governance > Third-party systems > Messaging components (Integration) > MOM components
Data Quality and Preparation > Third-party systems > Messaging components (Integration) > MOM components
Design and Development > Third-party systems > Messaging components (Integration) > MOM components
Last publication date
2024-02-21

About this task

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.

Procedure

  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.