4.19. リングキューの設定

手順

1. <broker_instance_dir>/etc/broker.xml 設定ファイルを開きます。

2. 明示的なリングサイズが設定されていない一致するアドレスですべてのキューのデフォルトリングサイズを定義するには、address- setting 要素に default-ring-size の値を指定します。以下に例を示します。

   <address-settings>
      <address-setting match="ring.#">
         <default-ring-size>3</default-ring-size>
      </address-setting>
   </address-settings>

   default-ring-size パラメーターは、自動作成されるキューのデフォルトサイズを定義する場合に特に便利です。default-ring-size のデフォルト値は -1(サイズ制限なし) です。

3. 特定のキューにリングサイズを定義するには、queue 要素に ring-size キーを追加します。値を指定します。以下に例を示します。

   <addresses>
      <address name="myRing">
         <anycast>
            <queue name="myRing" ring-size="5" />
         </anycast>
      </address>
   </addresses>

1. プロデューサーは、ring-size="3" で設定したリングキューに 3 つのメッセージを送信します。

2. すべてのメッセージは即座にコンシューマーにディスパッチされます。

   この時点で、messageCount= 3 および deliveryCount= 3 です。

3. プロデューサーは別のメッセージをキューに送信します。その後、メッセージはコンシューマーにディスパッチされます。

   現在、messageCount = 4 および deliveryCount = 4 です。4 のメッセージ数は、設定されたリングサイズ 3 を超えています。ただし、ブローカーはキューから再配信メッセージを削除できません。

4. 現在は、メッセージを承認せずにコンシューマーが閉じられているとします。

   この場合、4 つのインポイントで承認されていないメッセージはブローカーにキャンセルされ、消費元の逆順でキューの先頭に追加されます。このアクションにより、設定されたリングサイズにキューが追加されます。リングキューはヘッドでメッセージの末尾にあるメッセージを優先するため、キューは最後のメッセージがキューの先頭に追加されていたため、プロデューサーによって送信された最初のメッセージを破棄します。トランザクションまたはコアセッションのロールバックは同じように処理されます。

1. 12:00 では、プロデューサーはメッセージ A を ring-size="3" で設定されたリングキューに送信します。メッセージは 12:05 に対してスケジュールされます。

   この時点で、messageCount= 1 および scheduledCount= 1 になります。

2. 12:01 では、プロデューサーはメッセージ B を同じリングキューに送信します。

   現在、messageCount= 2 および scheduledCount= 1。

3. 12:02 では、プロデューサーはメッセージ C を同じリングキューに送信します。

   現在、messageCount= 3 および scheduledCount= 1。

4. 12:03 時、プロデューサーはメッセージ D を同じリングキューに送信します。

   現在、messageCount= 4 および scheduledCount= 1。

   キューのメッセージ数は 4 で、設定されたリングサイズから 3 よりも大きい ようになりました。ただし、スケジュールされたメッセージはキューでは技術的ではありません (つまり、ブローカーにあり、キューに配置するようにスケジュールされています)。スケジュールされた配信時間 12:05 にすると、ブローカーはメッセージをキューのヘッドに配置します。ただし、リングキューが設定サイズをすでに到達しているため、スケジュールされたメッセージ A はすぐに削除されます。