コンストラクターの詳細

• SimpleBatchingStrategy

  public SimpleBatchingStrategy​(int batchSize,
                                int bufferLimit,
                                long timeout)

  パラメーター:

  batchSize - バッチサイズ。

  bufferLimit - 最大バッファサイズ。短いバッチをトリガーする可能性があります。単一のメッセージには適用されません。

  timeout - バッチタイムアウト。

メソッドの詳細

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