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.
Drop tFixedFlowInput, JMSOutput, JMSInput, and tLogRow onto the workspace.
Link tFixedFlowInput to JMSOutput using a Row > Main connection.
Link tFixedFlowInput to JMSInput using the OnSubjobOk trigger.
Link JMSInput to tLogRow using a Row > Main connection.
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:
Click the Edit schema button to open the schema editor.
Click the [+] button to add one column, namely messageContent, of the string type.
Click OK to validate the setup and close the editor.
Now appears the pop-up box that asks for schema propogation.
Click Yes to propagate the schema to the subsequent component.
Double-click JMSOutput to open its Basic settings view.
In the Module List list, select the library to be used, namely the activemq jar in this case.
In the Context Provider field, enter the context URI, "org.apache.activemq.jndi.ActiveMQInitialContextFactory" in this case.
In the Server URL field, enter the ActiveMQ Server URI.
In the Connection Factory JDNI Name field, enter the JDNI name, "QueueConnectionFactory" in this case.
Select the Use Specified User Identity check box to show the User Name and Password fields, where you can enter the authentication data.
In the Message type list, select Queue.
In the Processing Mode list, select Message Content.
Perform the same setup in the Basic settings view of JMSInput.