Scenario: Enqueuing/dequeuing a message on the ActiveMQ 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

In this scenario, JMSOutput sends a message to a queue on the ActiveMQ server, which is then retrieved by JMSInput. This message is finally displayed on the console via tLogRow.

Linking the components

  1. Drop tFixedFlowInput, JMSOutput, JMSInput, and tLogRow onto the workspace.

  2. Link tFixedFlowInput to JMSOutput using a Row > Main connection.

  3. Link tFixedFlowInput to JMSInput using the OnSubjobOk trigger.

  4. Link JMSInput to tLogRow using a Row > Main connection.

Configuring the components

  1. Double-click tFixedFlowInput to open its Basic settings view.

    Select Use Inline Content (delimited file) in the Mode area.

    In the Content field, enter the content of the message to be sent to the ActiveMQ server:

    message transferred
  2. Click the Edit schema button to open the schema editor.

  3. Click the [+] button to add one column, namely messageContent, of the string type.

    Click OK to validate the setup and close the editor.

  4. Now appears the pop-up box that asks for schema propogation.

    Click Yes to propagate the schema to the subsequent component.

  5. Double-click JMSOutput to open its Basic settings view.

  6. In the Module List list, select the library to be used, namely the activemq jar in this case.

  7. In the Context Provider field, enter the context URI, "org.apache.activemq.jndi.ActiveMQInitialContextFactory" in this case.

  8. In the Server URL field, enter the ActiveMQ Server URI.

  9. In the Connection Factory JDNI Name field, enter the JDNI name, "QueueConnectionFactory" in this case.

  10. Select the Use Specified User Identity check box to show the User Name and Password fields, where you can enter the authentication data.

  11. In the Message type list, select Queue.

  12. In the Processing Mode list, select Message Content.

  13. Perform the same setup in the Basic settings view of JMSInput.

Executing the Job

  1. Press Ctrl + S to save the Job.

  2. Press F6 to run the Job. Note that the ActiveMQ server has started at tcp://192.168.30.46:61616.

    As shown above, the message is correctly transferred and displayed.