インターフェース BatchingStrategy

メソッドの詳細

• 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)