インターフェース BatchingStrategy
- すべての既知の実装クラス:
SimpleBatchingStrategy
public interface BatchingStrategyメッセージをバッチ処理するための戦略。メソッドが同時に呼び出されることはありません。実験用 - API は変更される場合があります。
- 導入:
- 1.4.1
- 作成者:
- Gary Russell
方法の概要
すべてのメソッド インスタンスメソッド 抽象メソッド デフォルトメソッド 修飾子と型 メソッド 説明 MessageBatchaddToBatch(StringSE exchange, StringSE routingKey, Message message)バッチにメッセージを追加し、必要に応じてバッチを解放します。default booleancanDebatch(MessageProperties properties)この戦略がメッセージ本文からメッセージのバッチをデコードできる場合は true を返します。default voiddeBatch(Message message, ConsumerSE<Message> fragmentConsumer)メッセージをフラグメントにデコードします。DateSEnextRelease()CollectionSE<MessageBatch>releaseBatches()おそらくタイムアウトが原因で、バッチをリリースします。
メソッドの詳細
addToBatch
MessageBatch addToBatch(StringSE exchange, StringSE routingKey, Message message)
バッチにメッセージを追加し、必要に応じてバッチを解放します。- パラメーター:
exchange- 交換。routingKey- ルーティングキー。message- メッセージ。- 戻り値:
- バッチ処理されたメッセージ (
MessageBatch)、または解放する準備ができていない場合は null。
nextRelease
DateSE nextRelease()
- 戻り値:
- 次にスケジュールされたリリースが実行される日付、またはリリースするデータがない場合は null。
releaseBatches
CollectionSE<MessageBatch> releaseBatches()
おそらくタイムアウトが原因で、バッチをリリースします。- 戻り値:
- バッチ処理されたメッセージ。
canDebatch
default boolean canDebatch(MessageProperties properties)
この戦略がメッセージ本文からメッセージのバッチをデコードできる場合は true を返します。true を返すということは、deBatch(Message, Consumer)をオーバーライドする必要があることを意味します。- パラメーター:
properties- メッセージのプロパティ。- 戻り値:
- メッセージをデコードできる場合は true。
- 導入:
- 2.2
- 関連事項:
deBatch(Message, Consumer)
deBatch
default void deBatch(Message message, ConsumerSE<Message> fragmentConsumer)
メッセージをフラグメントにデコードします。- パラメーター:
message- メッセージ。fragmentConsumer- フラグメントのコンシューマー。- 導入:
- 2.2
- 関連事項:
canDebatch(MessageProperties)