パッケージ org.springframework.modulith.events

クラス ResubmissionOptions

java.lang.ObjectSE
org.springframework.modulith.events.ResubmissionOptions
public class ResubmissionOptions extends ObjectSE
EventPublication の再提出時に考慮すべきオプション。
導入:
2.0
作成者:
Oliver Drotbohm

  • 方法の詳細

    • defaults

      public static ResubmissionOptions defaults()
      実行中の公開に制限がなく、バッチサイズが 100、最小期間がなく、すべての EventPublication インスタンスを含む新しい ResubmissionOptions を作成します。
      戻り値:
      null になることはありません。

    • getMaxInFlight

      public int getMaxInFlight()

    • withMaxInFlight

      public ResubmissionOptions withMaxInFlight(int maxInFlight)
      同時に処理されるパブリケーションの数を設定します。これは、再送信の試行ごとに、設定された値以下の数のみが再送信されることを意味します。
      パラメーター:
      maxInFlight - 0 以下であってはなりません。
      戻り値:
      null になることはありません。

    • getBatchSize

      public int getBatchSize()

    • withBatchSize

      public ResubmissionOptions withBatchSize(int batchSize)
      データベースからパブリケーションを読み取るためのバッチサイズを構成します。
      パラメーター:
      batchSize - 0 以下であってはなりません。
      戻り値:
      null になることはありません。

    • getMinAge

      public DurationSE getMinAge()

    • withMinAge

      public ResubmissionOptions withMinAge(DurationSE minAge)
      再送信の対象となるイベント公開の最小期間を設定します。
      パラメーター:
      minAge - null または負の数であってはなりません。
      戻り値:
      null になることはありません。

    • getFilter

      public PredicateSE<EventPublication> getFilter()

    • withFilter

      public ResubmissionOptions withFilter(PredicateSE<EventPublication> filter)
      再送信の試行で再送信する EventPublication を構成します。
      パラメーター:
      filter - null であってはなりません。
      戻り値:
      null になることはありません。