com.amazonaws.services.sqs.buffered

クラス NiftyReceiveAndDeleteQueueBuffer

java.lang.Object

com.amazonaws.services.sqs.buffered.NiftyReceiveAndDeleteQueueBuffer

public class NiftyReceiveAndDeleteQueueBuffer
extends java.lang.Object

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

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

メソッドの概要

メソッド

修飾子とタイプ	メソッドと説明
void	clear() バッファ内のプリフェッチメッセージをクリアします。
com.amazonaws.services.sqs.buffered.QueueBufferFuture<ReceiveMessageRequest,ReceiveMessageResult>	niftyReceiveAndDeleteMessageAsync(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()

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

niftyReceiveAndDeleteMessageAsync

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

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

戻り値:

null 以外。

clear

public void clear()

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