コンポーネントを設定 - 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. AMQ_Send_ConnectionFactoryという名前のcMQConnectionFactoryコンポーネントをダブルクリックして、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
  2. [MQ Server] (MQサーバー)リストからMQサーバーを選択します。このユースケースでは、デフォルトのActiveMQサーバーを使ってメッセージを処理します。
  3. [Broker URI] (ブローカーURI)フィールドにローカルActive MQサーバーのデフォルトのURIを入力します: "tcp://localhost:61616"
  4. DatasetConfigという名前のcConfigコンポーネントをダブルクリックして、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開き、パラメーターを設定します。
  5. 以下に示すように、[Code] (コード)フィールドにコードを記述して、データセットインスタンスhelloをレジストリーに登録します。
    org.apache.camel.component.dataset.SimpleDataSet dataset = new 
    org.apache.camel.component.dataset.SimpleDataSet(1);
    dataset.setDefaultBody("Test Data: hello world!");
    org.apache.camel.impl.SimpleRegistry registry = new  
    org.apache.camel.impl.SimpleRegistry();
         registry.put("hello",dataset);
    camelContext.setRegistry(registry); 
  6. SimpleDatasetGenという名前のcMessagingEndpointコンポーネントをダブルクリックして、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開き、パラメーターを設定します。
  7. URIフィールドに、引用符で囲んでdataset:helloと入力します。
  8. AMQ_Send という名前のcJMSコンポーネントをダブルクリックし、[Basic settings] (基本設定)ビューを開きます。
  9. [Type] (タイプ)リストから、JMSキューにメッセージを送信するための[queue] (キュー)を選択します。
    [Destination] (デスティネーション)フィールドにJMSキューの名前を入力します。この場合は "queue.hello"です。
    ConnectionFactoryの横にある[...]ボタンをダブルクリックします。ダイアログボックスで設定したばかりのMQ接続ファクトリーを選択し、[OK]をクリックします。
  10. PrintSendMsgという名前のcProcessorコンポーネントをダブルクリックして、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開き、[Code] (コード)エリア内のコードをカスタマイズして、コンソールにインターセプトされた受信メッセージを表示します。
    System.out.println("AMQ Send: "+
    exchange.getIn().getBody(String.class));