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

コンポーネントの設定を定義

手順

  1. AMQ_Rev_ConnectionFactoryという名前のcMQConnectionFactoryコンポーネントをダブルクリックして、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開きます。
  2. [MQ Server] (MQサーバー)リストからMQサーバーを選択します。このユースケースでは、デフォルトのActiveMQサーバーを使ってメッセージを処理します。
    [Use Transaction] (トランザクションの使用)チェックボックスをオンにします。
  3. [Broker URI] (ブローカーURI)フィールドにローカルActive MQサーバーのデフォルトのURIを入力します: "tcp://localhost:61616"。
  4. AMQ_Revという名前のcJMSコンポーネントをダブルクリックし、[Basic settings] (基本設定)ビューを開きます。
  5. [Type] (タイプ)リストから、JMSキューにメッセージを送信するための[queue] (キュー)を選択します。
    [Destination] (デスティネーション)フィールドにJMSキューの名前を入力します。この場合は "queue.hello"です。
    ConnectionFactoryの横にある[...]ボタンをダブルクリックします。ダイアログボックスで設定したばかりのMQ接続ファクトリーを選択し、[OK]をクリックします。
  6. PrintRevMsgという名前のcProcessorコンポーネントをダブルクリックして、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開き、[Code] (コード)エリア内のコードをカスタマイズして、コンソールにインターセプトされた受信メッセージを表示します。 
    System.out.println("AMQ Receive: "+
exchange.getIn().getBody(String.class));
  7. ThrowExという名前の2番目のcProcessorコンポーネントをダブルクリックして、[Component] (コンポーネント)タブで[Basic settings] (基本設定)ビューを開き、[Code] (コード)エリアのコードをカスタマイズして、交換がルートによって処理されるたびにForce fail例外を返すようにします。 
    throw new Exception("Force fail")

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

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

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