クラス SimpleBatchingStrategy
java.lang.ObjectSE
org.springframework.amqp.rabbit.batch.SimpleBatchingStrategy
- 実装されているすべてのインターフェース:
BatchingStrategy
A simple batching strategy that supports only one exchange/routingKey; includes a batch size, a batched message size limit and a timeout. The message properties from the first message in the batch are used in the batch message. Each message is preceded by a 4-byte length field.
- 導入:
- 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
- 関連事項: