7.8.2. クライアントの接続
AMQ Broker CLI を使用して、クラスターのブローカーにラウンドロビンされるコンシューマーを作成します。
手順
端末でコンシューマーを作成し、OpenShift が実行している IP アドレスにアタッチします。
artemis consumer --url tcp://<IP_ADDRESS>:30001 --message-count 100 --destination queue://demoQueue
ステップ 1 を 2 回繰り返して、2 つのコンシューマーを起動します。
注記これで、3 つのブローカー全体で 3 つのコンシューマー負荷が分散されます。
メッセージを送信するプロデューサーを作成します。
artemis producer --url tcp://<IP_ADDRESS>:30001 --message-count 300 --destination queue://demoQueue
各コンシューマーがメッセージを受信することを確認します。
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