メイン コンテンツをスキップする 補完的コンテンツへスキップ

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

手順

  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));

このページは役に立ちましたか?

このページまたはコンテンツにタイポ、ステップの省略、技術的エラーなどの問題が見つかった場合はお知らせください。

こちらにフィードバックをお寄せください