クラス SimpleBatchingStrategy
java.lang.ObjectSE
org.springframework.amqp.rabbit.batch.SimpleBatchingStrategy
- 実装されているすべてのインターフェース:
BatchingStrategy
1 つの exchange/routingKey のみをサポートするシンプルなバッチ処理戦略です。バッチサイズ、バッチ処理されるメッセージのサイズ制限、タイムアウトが含まれます。バッチ処理の最初のメッセージのメッセージプロパティがバッチメッセージで使用されます。各メッセージの前には 4 バイトの長さフィールドが付きます。
- 導入:
- 1.4.1
- 作成者:
- Gary Russell, Ngoc Nhan, Artem Bilan
コンストラクターの概要
コンストラクターメソッドのサマリー
修飾子と型メソッド説明@Nullable MessageBatchaddToBatch(@Nullable StringSE exch, @Nullable StringSE routKey, Message message) バッチにメッセージを追加し、必要に応じてバッチを解放します。booleancanDebatch(MessageProperties properties) この戦略がメッセージ本文からメッセージのバッチをデコードできる場合は true を返します。voiddeBatch(Message message, ConsumerSE<Message> fragmentConsumer) MessageProperties.SPRING_BATCH_FORMATがMessageProperties.BATCH_FORMAT_LENGTH_HEADER4に設定されたヘッダーを持つメッセージをデバッチします。@Nullable DateSEおそらくタイムアウトが原因で、バッチをリリースします。
コンストラクターの詳細
SimpleBatchingStrategy
public SimpleBatchingStrategy(int batchSize, int bufferLimit, long timeout) - パラメーター:
batchSize- バッチサイズ。bufferLimit- 最大バッファサイズ。短いバッチをトリガーする可能性があります。単一のメッセージには適用されません。timeout- バッチタイムアウト。
メソッドの詳細
addToBatch
public @Nullable MessageBatch addToBatch(@Nullable StringSE exch, @Nullable StringSE routKey, Message message) インターフェースからコピーされた説明:BatchingStrategyバッチにメッセージを追加し、必要に応じてバッチを解放します。- 次で指定:
- インターフェース
BatchingStrategyのaddToBatch - パラメーター:
exch- 交換。routKey- ルーティングキー。message- メッセージ。- 戻り値:
- バッチ処理されたメッセージ (
MessageBatch)、または解放する準備ができていない場合は null。
nextRelease
- 次で指定:
- インターフェース
BatchingStrategyのnextRelease - 戻り値:
- 次にスケジュールされたリリースが実行される日付、またはリリースするデータがない場合は null。
releaseBatches
インターフェースからコピーされた説明:BatchingStrategyおそらくタイムアウトが原因で、バッチをリリースします。- 次で指定:
- インターフェース
BatchingStrategyのreleaseBatches - 戻り値:
- バッチ処理されたメッセージ。
canDebatch
インターフェースからコピーされた説明:BatchingStrategyこの戦略がメッセージ本文からメッセージのバッチをデコードできる場合は true を返します。true を返すということは、BatchingStrategy.deBatch(Message, Consumer)をオーバーライドする必要があることを意味します。- 次で指定:
- インターフェース
BatchingStrategyのcanDebatch - パラメーター:
properties- メッセージのプロパティ。- 戻り値:
- メッセージをデコードできる場合は true。
- 関連事項:
deBatch
MessageProperties.SPRING_BATCH_FORMATがMessageProperties.BATCH_FORMAT_LENGTH_HEADER4に設定されたヘッダーを持つメッセージをデバッチします。- 次で指定:
- インターフェース
BatchingStrategyのdeBatch - パラメーター:
message- バッチメッセージ。fragmentConsumer- 各フラグメントのコンシューマー。- 導入:
- 2.2
- 関連事項: