クラス SimpleBatchingStrategy
java.lang.ObjectSE
org.springframework.amqp.rabbit.batch.SimpleBatchingStrategy
- 実装されたすべてのインターフェース:
BatchingStrategy
1 つの exchange/routingKey のみをサポートする単純なバッチ処理戦略。バッチサイズ、バッチメッセージのサイズ制限、およびタイムアウトが含まれます。バッチ内の最初のメッセージのメッセージプロパティがバッチメッセージで使用されます。各メッセージの前には、4 バイトの長さフィールドがあります。
- 導入:
- 1.4.1
- 作成者:
- Gary Russell
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明addToBatch(StringSE exch, StringSE routKey, Message message) バッチにメッセージを追加し、必要に応じてバッチを解放します。booleancanDebatch(MessageProperties properties) この戦略がメッセージ本文からメッセージのバッチをデコードできる場合は true を返します。voiddeBatch(Message message, ConsumerSE<Message> fragmentConsumer) MessageProperties.SPRING_BATCH_FORMATがMessageProperties.BATCH_FORMAT_LENGTH_HEADER4に設定されたヘッダーを持つメッセージをデバッチします。おそらくタイムアウトが原因で、バッチをリリースします。
コンストラクターの詳細
SimpleBatchingStrategy
public SimpleBatchingStrategy(int batchSize, int bufferLimit, long timeout) - パラメーター:
batchSize- バッチサイズ。bufferLimit- 最大バッファサイズ。短いバッチをトリガーする可能性があります。単一のメッセージには適用されません。timeout- バッチタイムアウト。
メソッドの詳細
addToBatch
インターフェースからコピーされた説明: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
- 関連事項: