クラス SimpleBatchingStrategy

メソッドの詳細

• addToBatch

  public MessageBatch addToBatch(StringSE exch, StringSE routKey, Message message)

  インターフェースからコピーされた説明: BatchingStrategy

  バッチにメッセージを追加し、必要に応じてバッチを解放します。

  次で指定:

  インターフェース BatchingStrategy の addToBatch 

  パラメーター:

  exch - 交換。

  routKey - ルーティングキー。

  message - メッセージ。

  戻り値:

  バッチ処理されたメッセージ ( MessageBatch )、または解放する準備ができていない場合は null。

• nextRelease

  public DateSE nextRelease()

  次で指定:

  インターフェース BatchingStrategy の nextRelease 

  戻り値:

  次にスケジュールされたリリースが実行される日付、またはリリースするデータがない場合は null。

• releaseBatches

  public CollectionSE<MessageBatch> releaseBatches()

  インターフェースからコピーされた説明: BatchingStrategy

  おそらくタイムアウトが原因で、バッチをリリースします。

  次で指定:

  インターフェース BatchingStrategy の releaseBatches 

  戻り値:

  バッチ処理されたメッセージ。

• canDebatch

  public boolean canDebatch(MessageProperties properties)

  インターフェースからコピーされた説明: BatchingStrategy

  この戦略がメッセージ本文からメッセージのバッチをデコードできる場合は true を返します。true を返すということは、BatchingStrategy.deBatch(Message, Consumer) をオーバーライドする必要があることを意味します。

  次で指定:

  インターフェース BatchingStrategy の canDebatch 

  パラメーター:

  properties - メッセージのプロパティ。

  戻り値:

  メッセージをデコードできる場合は true。

  関連事項:

  • BatchingStrategy.deBatch(Message, Consumer)

• deBatch

  public void deBatch(Message message, ConsumerSE<Message> fragmentConsumer)

  MessageProperties.SPRING_BATCH_FORMAT が MessageProperties.BATCH_FORMAT_LENGTH_HEADER4 に設定されたヘッダーを持つメッセージをデバッチします。

  次で指定:

  インターフェース BatchingStrategy の deBatch 

  パラメーター:

  message - バッチメッセージ。

  fragmentConsumer - 各フラグメントのコンシューマー。

  導入:

  2.2

  関連事項:

  • BatchingStrategy.canDebatch(MessageProperties)