public class QueueBufferConfig
extends java.lang.Object
| 修飾子とタイプ | フィールドと説明 |
|---|---|
static int |
LONGPOLL_WAIT_TIMEOUT_SECONDS_DEFAULT |
static long |
MAX_BATCH_OPEN_MS_DEFAULT
200 ミリ秒
|
static long |
MAX_BATCH_SIZE_BYTES |
static long |
MAX_BATCH_SIZE_BYTES_DEFAULT
64 KB
|
static int |
MAX_BATCH_SIZE_DEFAULT |
static int |
MAX_DONE_RECEIVE_BATCHES_DEFAULT
10 バッチ
|
static int |
MAX_INFLIGHT_OUTBOUND_BATCHES_DEFAULT
5 バッチ
|
static int |
MAX_INFLIGHT_RECEIVE_BATCHES_DEFAULT
10 バッチ
|
static int |
VISIBILITY_TIMEOUT_SECONDS_DEFAULT
キューのタイムアウト(-1:デフォルトタイムアウトを使用)
|
| コンストラクタと説明 |
|---|
QueueBufferConfig() |
QueueBufferConfig(long maxBatchOpenMs,
int maxInflightOutboundBatches,
int maxInflightReceiveBatches,
int maxDoneReceiveBatches,
boolean paramLongPoll,
long maxBatchSizeBytes,
int visibilityTimeout,
int longPollTimeout,
int maxBatch) |
QueueBufferConfig(QueueBufferConfig other)
コピー コンストラクタ
|
| 修飾子とタイプ | メソッドと説明 |
|---|---|
int |
getLongPollWaitTimeoutSeconds()
受信呼び出しは秒単位で指定し、キューが空になるまでサーバー上でブロックされます。
|
long |
getMaxBatchOpenMs()
追加のアウトバウンド要求のため送信バッチを開いたままとする最大時間(ミリ秒)。
|
int |
getMaxBatchSize()
バッファクライアントが単一のバッチリクエストに入れるエントリの最大数を指定します。
|
long |
getMaxBatchSizeBytes()
SendMessage または SendMessageBatch メッセージの最大サイズ。
|
int |
getMaxDoneReceiveBatches()
バッファで待機している受信完了バッチ数がその値を超えた場合、新しいメッセージのクエリを停止します。
|
int |
getMaxInflightOutboundBatches()
アウトバウンド要求の種類別 同時バッチ最大数。
|
int |
getMaxInflightReceiveBatches()
同時受信するメッセージバッチの最大数。
|
int |
getVisibilityTimeoutSeconds()
キューからメッセージを取得するときに使用するカスタムタイムアウト。
|
boolean |
isLongPoll() |
void |
setLongPoll(boolean longPoll)
Long-Pollを使用する受信要求に対しては、"true"を指定。
|
void |
setLongPollWaitTimeoutSeconds(int longPollWaitTimeoutSeconds)
受信呼び出しは秒単位で指定し、キューが空になるまでサーバー上でブロックされます。
|
void |
setMaxBatchOpenMs(long maxBatchOpenMs)
追加のアウトバウンド要求のため送信バッチを開いたままとする最大時間(ミリ秒)。
|
void |
setMaxBatchSize(int maxBatchSize)
バッファクライアントが単一のバッチリクエストに入れるエントリの最大数を指定します。
|
void |
setMaxBatchSizeBytes(long maxBatchSizeBytes)
SendMessage または SendMessageBatch メッセージの最大サイズ。
|
void |
setMaxDoneReceiveBatches(int maxDoneReceiveBatches)
バッファで待機している受信完了バッチ数がその値を超えた場合、新しいメッセージのクエリを停止します。
|
void |
setMaxInflightOutboundBatches(int maxInflightOutboundBatches)
アウトバウンド要求の種類別 同時バッチ最大数。
|
void |
setMaxInflightReceiveBatches(int maxInflightReceiveBatches)
同時受信するメッセージバッチの最大数。
|
void |
setVisibilityTimeoutSeconds(int visibilityTimeoutSeconds)
キューからメッセージを取得するときに使用するカスタムタイムアウト。
|
java.lang.String |
toString() |
QueueBufferConfig |
withLongPoll(boolean longPoll) |
QueueBufferConfig |
withLongPollWaitTimeoutSeconds(int longPollWaitTimeoutSeconds) |
QueueBufferConfig |
withMaxBatchOpenMs(long maxBatchOpenMs) |
QueueBufferConfig |
withMaxBatchSize(int maxBatchSize)
バッファクライアントが単一のバッチリクエストに入れるエントリの最大数を指定します。
|
QueueBufferConfig |
withMaxBatchSizeBytes(long maxBatchSizeBytes) |
QueueBufferConfig |
withMaxDoneReceiveBatches(int maxDoneReceiveBatches) |
QueueBufferConfig |
withMaxInflightOutboundBatches(int maxInflightOutboundBatches) |
QueueBufferConfig |
withMaxInflightReceiveBatches(int maxInflightReceiveBatches) |
QueueBufferConfig |
withVisibilityTimeoutSeconds(int visibilityTimeoutSeconds) |
public static final int MAX_BATCH_SIZE_DEFAULT
public static final long MAX_BATCH_SIZE_BYTES
public static final long MAX_BATCH_OPEN_MS_DEFAULT
public static final int MAX_INFLIGHT_OUTBOUND_BATCHES_DEFAULT
public static final int MAX_INFLIGHT_RECEIVE_BATCHES_DEFAULT
public static final int MAX_DONE_RECEIVE_BATCHES_DEFAULT
public static final long MAX_BATCH_SIZE_BYTES_DEFAULT
public static final int VISIBILITY_TIMEOUT_SECONDS_DEFAULT
public static final int LONGPOLL_WAIT_TIMEOUT_SECONDS_DEFAULT
public QueueBufferConfig(long maxBatchOpenMs,
int maxInflightOutboundBatches,
int maxInflightReceiveBatches,
int maxDoneReceiveBatches,
boolean paramLongPoll,
long maxBatchSizeBytes,
int visibilityTimeout,
int longPollTimeout,
int maxBatch)
public QueueBufferConfig()
public QueueBufferConfig(QueueBufferConfig other)
public java.lang.String toString()
toString クラス内 java.lang.Objectpublic long getMaxBatchOpenMs()
public void setMaxBatchOpenMs(long maxBatchOpenMs)
public QueueBufferConfig withMaxBatchOpenMs(long maxBatchOpenMs)
public boolean isLongPoll()
public void setLongPoll(boolean longPoll)
public QueueBufferConfig withLongPoll(boolean longPoll)
public int getMaxInflightOutboundBatches()
public void setMaxInflightOutboundBatches(int maxInflightOutboundBatches)
public QueueBufferConfig withMaxInflightOutboundBatches(int maxInflightOutboundBatches)
public int getMaxInflightReceiveBatches()
public void setMaxInflightReceiveBatches(int maxInflightReceiveBatches)
public QueueBufferConfig withMaxInflightReceiveBatches(int maxInflightReceiveBatches)
public int getMaxDoneReceiveBatches()
public void setMaxDoneReceiveBatches(int maxDoneReceiveBatches)
public QueueBufferConfig withMaxDoneReceiveBatches(int maxDoneReceiveBatches)
public long getMaxBatchSizeBytes()
public void setMaxBatchSizeBytes(long maxBatchSizeBytes)
public QueueBufferConfig withMaxBatchSizeBytes(long maxBatchSizeBytes)
public int getVisibilityTimeoutSeconds()
public void setVisibilityTimeoutSeconds(int visibilityTimeoutSeconds)
public QueueBufferConfig withVisibilityTimeoutSeconds(int visibilityTimeoutSeconds)
public void setLongPollWaitTimeoutSeconds(int longPollWaitTimeoutSeconds)
public int getLongPollWaitTimeoutSeconds()
public QueueBufferConfig withLongPollWaitTimeoutSeconds(int longPollWaitTimeoutSeconds)
public int getMaxBatchSize()
public void setMaxBatchSize(int maxBatchSize)
public QueueBufferConfig withMaxBatchSize(int maxBatchSize)