7.8.2. クライアントの接続

AMQ Broker CLI を使用して、クラスターのブローカーにラウンドロビンされるコンシューマーを作成します。

手順

  1. 端末でコンシューマーを作成し、OpenShift が実行している IP アドレスにアタッチします。

    artemis consumer --url tcp://<IP_ADDRESS>:30001 --message-count 100 --destination queue://demoQueue
  2. ステップ 1 を 2 回繰り返して、2 つのコンシューマーを起動します。

    注記

    これで、3 つのブローカー全体で 3 つのコンシューマー負荷が分散されます。

  3. メッセージを送信するプロデューサーを作成します。

    artemis producer --url tcp://<IP_ADDRESS>:30001 --message-count 300 --destination queue://demoQueue
  4. 各コンシューマーがメッセージを受信することを確認します。

    Consumer:: filter = null
    Consumer ActiveMQQueue[demoQueue], thread=0 wait until 100 messages are consumed
    Consumer ActiveMQQueue[demoQueue], thread=0 Consumed: 100 messages
    Consumer ActiveMQQueue[demoQueue], thread=0 Consumer thread finished