メッセージの処理方法の設定 - 7.2

JMS (メディエーション)
Version
7.2
Language
日本語 (日本)
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
ジョブデザインと開発 > サードパーティーシステム > メッセージブローカー > JMSコンポーネント(メディエーション)
データガバナンス > サードパーティーシステム > メッセージブローカー > JMSコンポーネント(メディエーション)
データクオリティとプレパレーション > サードパーティーシステム > メッセージブローカー > JMSコンポーネント(メディエーション)

手順

  1. cMQConnectionFactoryコンポーネントをダブルクリックし、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
  2. [MQ Server] (MQサーバー)リストからMQサーバーを選択します。このユースケースでは、デフォルトのActiveMQサーバーを使ってメッセージを処理します。
  3. [Broker URI] (ブローカーURI)フィールドにローカルActive MQサーバーのデフォルトのURIを入力します: "tcp://localhost:61616"。
  4. DeadLetterQueueJMSという名前のcJMSコンポーネントをダブルクリックし、[Basic settings] (基本設定)ビューを開きます。
  5. [Type] (タイプ)リストから、JMSキューにメッセージを送信するための[queue] (キュー)を選択します。
    [Destination] (デスティネーション)フィールドにJMSキューの名前(このユースケースでは"ActiveMQ.DLQ")を入力します(デフォルトはActiveMQのDead Letterキューになります)。
    ConnectionFactoryの横にある[...]ボタンをダブルクリックします。ダイアログボックスで設定したばかりのMQ接続ファクトリーを選択し、[OK]をクリックします。
  6. PrintMsgという名前のcProcessorコンポーネントをダブルクリックして、[Component] (コンポーネント)タブに[Basic settings] (基本設定)ビューを表示し、[Code] (コード)エリア内のコードをカスタマイズして、コンソールにインターセプトされた受信メッセージを表示します。 
    System.out.println("AMQ Receive: "+ 
exchange.getIn().getBody(String.class));