Defining the settings of the components

Defining the settings of the components - 7.3

JMS (Mediation)

Version

7.3

Language

English

Product

Talend Data Fabric

Talend Data Services Platform

Talend ESB

Talend MDM Platform

Talend Open Studio for ESB

Talend Real-Time Big Data Platform

Module

Talend Studio

Content

Data Governance > Third-party systems > Messaging components (Mediation) > JMS components (Mediation)

Data Quality and Preparation > Third-party systems > Messaging components (Mediation) > JMS components (Mediation)

Design and Development > Third-party systems > Messaging components (Mediation) > JMS components (Mediation)

Last publication date

2023-06-12

Double-click the cMQConnectionFactory component labelled AMQ_Rev_ConnectionFactory to display its Basic settings view in the Component tab.
From the MQ Server list, select an MQ server. In this use case, we use the default ActiveMQ server to handle the messages.
Select the Use transaction check box.
In the Broker URI field, type in Active MQ's default URI of the localhost server: "tcp://localhost:61616".
Double-click the cJMS component labeled AMQ_Rev to display its Basic settings view.
From the Type list, select queue to send the messages to a JMS queue.
In the Destination field, type in a name for the JMS queue, "queue.hello" in this use case.

Double-click the [...] button next to ConnectionFactory. Select the MQ connection factory that you have just configured in the dialog box and click OK.
Double-click the first cProcessor component labelled PrintRevMsg to display its Basic settings view in the Component tab, and customize the code in the Code area to display the received message intercepted on the console.
```
System.out.println("AMQ Receive: "+
exchange.getIn().getBody(String.class));
```
Double-click the second cProcessor component labelled ThrowEx to display its Basic settings view in the Component tab, and customize the code in the Code area to throw the Force fail exception every time an exchange is processed by the route.
```
throw new Exception("Force fail")
```