com.amazonaws.services.sqs.buffered

## クラス ReceiveQueueBuffer

- java.lang.Object
- - com.amazonaws.services.sqs.buffered.ReceiveQueueBuffer

-     public class ReceiveQueueBuffer
      extends java.lang.Object

  ReceiveQueueBuffer クラスは単一 SQS キューからのメッセージ取得を行います。 指定されたExecutorを使用して、サーバからメッセージをプリフェッチする 着信方向の要求を満たすためのバッファに保持されます。 バッファ内にプリフェッチされた状態とする要求数は、メッセージ取得するために 使用するスレッドの最大数と同様に、構成可能です。

  同期戦略: - スレッドは、新しいタスクの生成または進行中のタスク数を変更するため TaskSpawnSyncPoint オブジェクトモニターを保持する必要があります。 - スレッドは、一覧を変更するため「futures」リストのモニターを保持する必要があります。 - スレッドは、一覧を変更するため「finishedTasks」リストのモニターを保持する必要があります。 - 「futures」と「finishedTasks」の両方をロックする場合は、先に「futures」をロックし、 次に「finishedTasks」をロックします。

- - ### メソッドの概要

    メソッド
    修飾子とタイプ | メソッドと説明
    --- | ---
    `void` | `clear()` バッファ内のプリフェッチメッセージをクリアします。
    `com.amazonaws.services.sqs.buffered.QueueBufferFuture<ReceiveMessageRequest,ReceiveMessageResult>` | `receiveMessageAsync(ReceiveMessageRequest rq, com.amazonaws.services.sqs.buffered.QueueBufferCallback<ReceiveMessageRequest,ReceiveMessageResult> callback)` キューからメッセージを取得するため要求を送信し、要求が満たされた場合の通知を返します。
    `void` | `shutdown()` 新しい検索のバッチの生成を防ぎ、処理中検索バッチが完了するまで待機します。

    - ### クラスから継承されたメソッド java.lang.Object

      `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- - ### メソッドの詳細

    - #### shutdown

          public void shutdown()

      新しい検索のバッチの生成を防ぎ、処理中検索バッチが完了するまで待機します。

    - #### receiveMessageAsync

          public com.amazonaws.services.sqs.buffered.QueueBufferFuture<ReceiveMessageRequest,ReceiveMessageResult> receiveMessageAsync(ReceiveMessageRequest rq,
                                                                                                                              com.amazonaws.services.sqs.buffered.QueueBufferCallback<ReceiveMessageRequest,ReceiveMessageResult> callback)

      キューからメッセージを取得するため要求を送信し、要求が満たされた場合の通知を返します。 返された時点で既に通知されている可能性があります。
      戻り値:
        null 以外。

    - #### clear

          public void clear()

      バッファ内のプリフェッチメッセージをクリアします。