Defining the settings of the components
-
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.12System.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.1throw new Exception("Force fail")
Document get from Talend https://help.talend.com
Thank you for watching.
Subscribe
Login
0 Comments