Skip to main content Skip to complementary content

Configuring how the message is processed

Procedure

  1. Double-click the cMQConnectionFactory component to display its Basic settings view in the Component tab.
  2. From the MQ Server list, select an MQ server. In this use case, we use the default ActiveMQ server to handle the messages.
  3. In the Broker URI field, type in Active MQ's default URI of the localhost server: "tcp://localhost:61616".
  4. Double-click the cJMS component labeled DeadLetterQueueJMS to display its Basic settings view.
  5. 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, "ActiveMQ.DLQ" in this use case (the default Dead Letter Queue in ActiveMQ).
    Double-click the [...] button next to ConnectionFactory. Select the MQ connection factory that you have just configured in the dialog box and click OK.
  6. Double-click the cProcessor component labelled PrintMsg 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));

Did this page help you?

If you find any issues with this page or its content – a typo, a missing step, or a technical error – let us know how we can improve!