com.amazonaws.services.sqs.buffered

クラス SendQueueBuffer

java.lang.Object

com.amazonaws.services.sqs.buffered.SendQueueBuffer

public class SendQueueBuffer
extends java.lang.Object

このクラスは、要求メッセージを送信、メッセージを削除して、 メッセージの表示を変更するSQS 要求をバッファリングします。
要求が到着すると、バッファが適切なタイプのメッセージバッチに （存在しない場合は新たに生成した上で）メッセージを追加します。 未処理のバッチがフルになったとき、またはタイムアウトで、 バッファは、現在のバッチを実行する SQS を呼び出します。
内部的には、バッチオブジェクトはそれらに追加されたリクエストに対応するFuturesリストを保持します。 バッチの完了時、Futuresに完了結果が読み込まれます。

メソッドの概要

メソッド

修飾子とタイプ	メソッドと説明
com.amazonaws.services.sqs.buffered.QueueBufferFuture<ChangeMessageVisibilityRequest,java.lang.Void>	changeMessageVisibility(ChangeMessageVisibilityRequest request, com.amazonaws.services.sqs.buffered.QueueBufferCallback<ChangeMessageVisibilityRequest,java.lang.Void> callback)
com.amazonaws.services.sqs.buffered.QueueBufferFuture<DeleteMessageRequest,java.lang.Void>	deleteMessage(DeleteMessageRequest request, com.amazonaws.services.sqs.buffered.QueueBufferCallback<DeleteMessageRequest,java.lang.Void> callback)
void	flush() バッファ内の全ての未処理の送信要求をフラッシュします。
QueueBufferConfig	getConfig()
com.amazonaws.services.sqs.buffered.QueueBufferFuture<SendMessageRequest,SendMessageResult>	sendMessage(SendMessageRequest request, com.amazonaws.services.sqs.buffered.QueueBufferCallback<SendMessageRequest,SendMessageResult> callback)

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

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

メソッドの詳細

getConfig

public QueueBufferConfig getConfig()

sendMessage

public com.amazonaws.services.sqs.buffered.QueueBufferFuture<SendMessageRequest,SendMessageResult> sendMessage(SendMessageRequest request,
                                                                                                      com.amazonaws.services.sqs.buffered.QueueBufferCallback<SendMessageRequest,SendMessageResult> callback)

戻り値:

null以外。

deleteMessage

public com.amazonaws.services.sqs.buffered.QueueBufferFuture<DeleteMessageRequest,java.lang.Void> deleteMessage(DeleteMessageRequest request,
                                                                                                       com.amazonaws.services.sqs.buffered.QueueBufferCallback<DeleteMessageRequest,java.lang.Void> callback)

戻り値:

null以外。

changeMessageVisibility

public com.amazonaws.services.sqs.buffered.QueueBufferFuture<ChangeMessageVisibilityRequest,java.lang.Void> changeMessageVisibility(ChangeMessageVisibilityRequest request,
                                                                                                                           com.amazonaws.services.sqs.buffered.QueueBufferCallback<ChangeMessageVisibilityRequest,java.lang.Void> callback)

戻り値:

null以外。

flush

public void flush()

バッファ内の全ての未処理の送信要求をフラッシュします。 （ SendMessage,DeleteMessage,ChangeMessageVisibility ）

SQSによって処理される未処理の送信要求が完了すると、呼び出しを正常に返します。