4.3. テストメッセージの生成および使用

手順

1. artemis producer コマンドを使用していくつかのテストメッセージを生成し、ブローカーに送信します。

   このコマンドは、ブローカーに自動的に作成される helloworld アドレスにメッセージを100個送信します。プロデューサーは、サポートされるすべてのメッセージングプロトコルを許可するデフォルトのポート 61616 を使用してブローカーに接続します。

   $ /opt/redhat/amq-broker/amq-broker-7.2.0/bin/artemis producer --destination helloworld --message-count 100 --url tcp://localhost:61616
   Producer ActiveMQQueue[helloworld], thread=0 Started to calculate elapsed time ...
   
   Producer ActiveMQQueue[helloworld], thread=0 Produced: 100 messages
   Producer ActiveMQQueue[helloworld], thread=0 Elapsed time in second : 1 s
   Producer ActiveMQQueue[helloworld], thread=0 Elapsed time in milli second : 1289 milli seconds

2. Web コンソールを使用して、ブローカーに保存されているメッセージを表示します。

   1. Web ブラウザーで 、http://localhost:8161 に移動します。

   2. ブローカーインスタンスの作成時に作成したデフォルトのユーザー名およびパスワードを使用して、コンソールにログインします。

      Attributes タブが表示されます。

   3. Attributes タブでメニュー:[addresses > helloworld > queues > "anycast" > helloworld] に移動します。

      前の手順で、helloworld アドレスにメッセージを送信しています。これにより、キュー (helloworldという名前) を持つ新しい anycast helloworld アドレスが作成されました。Message count 属性は、現在 helloworld に送信された 100 個のメッセージがすべてこのキューに保存されていることを示しています。

      図4.1 メッセージ数

      

3. artemis consumer コマンドを使用して、ブローカーに保存されているメッセージ 50 個を消費します。

   このコマンドは、以前にブローカーに送信されたメッセージの 50 を消費します。

   $ /opt/redhat/amq-broker/amq-broker-7.2.0/bin/artemis consumer --destination helloworld --message-count 50 --url tcp://localhost:61616
   
   Consumer:: filter = null
   Consumer ActiveMQQueue[helloworld], thread=0 wait until 50 messages are consumed
   Consumer ActiveMQQueue[helloworld], thread=0 Consumed: 50 messages
   Consumer ActiveMQQueue[helloworld], thread=0 Consumer thread finished

4. Web コンソールで、メッセージ数 が 50 であることを確認します。

   メッセージが 50 個消費され、helloworld キューに格納されているメッセージ数の残りは 50 個になります。

5. ブローカーを停止し、残りのメッセージ 50 個が helloworld キューに保存されていることを確認します。

   1. ブローカーが稼働しているターミナルで、Ctrl+C を押してブローカーを停止します。

   2. ブローカーを起動します。

      $ /var/opt/amq-broker/mybroker/bin/artemis run

   3. Web コンソールで、helloworld キューに戻り、キューに保存されているメッセージが 50 個であることを確認します。

6. 残りの 50 メッセージを消費します。

   $ /opt/redhat/amq-broker/amq-broker-7.2.0/bin/artemis consumer --destination helloworld --message-count 50 --url tcp://localhost:61616
   
   Consumer:: filter = null
   Consumer ActiveMQQueue[helloworld], thread=0 wait until 50 messages are consumed
   Consumer ActiveMQQueue[helloworld], thread=0 Consumed: 50 messages
   Consumer ActiveMQQueue[helloworld], thread=0 Consumer thread finished

7. Web コンソールで、メッセージ数 が 0 であることを確認します。

   helloworld キューに保存されているメッセージはすべて消費され、キューが空になりました。