インターフェース BatchingStrategy
- すべての既知の実装クラス:
SimpleBatchingStrategy
public interface BatchingStrategy
メッセージをバッチ処理するための戦略。メソッドが同時に呼び出されることはありません。実験用 - API は変更される場合があります。
- 導入:
- 1.4.1
- 作成者:
- Gary Russell
メソッドのサマリー
すべてのメソッド インスタンスメソッド 抽象メソッド デフォルトメソッド 修飾子と型 メソッド 説明 MessageBatch
addToBatch(StringSE exchange, StringSE routingKey, Message message)
バッチにメッセージを追加し、必要に応じてバッチを解放します。default boolean
canDebatch(MessageProperties properties)
この戦略がメッセージ本文からメッセージのバッチをデコードできる場合は true を返します。default void
deBatch(Message message, ConsumerSE<Message> fragmentConsumer)
メッセージをフラグメントにデコードします。DateSE
nextRelease()
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)