パッケージ org.springframework.data.redis.connection

クラス RedisStreamCommands.XClaimOptions

java.lang.ObjectSE
org.springframework.data.redis.connection.RedisStreamCommands.XClaimOptions
含まれているインターフェース:
RedisStreamCommands
public static class RedisStreamCommands.XClaimOptions extends ObjectSE
導入:
2.3
作成者:
Christoph Strobl

  • メソッドの詳細

    • minIdle

      public static RedisStreamCommands.XClaimOptions.XClaimOptionsBuilder minIdle(DurationSE minIdleTime)
      min-idle-time を設定して、少なくとも指定された DurationSE の間アイドル状態になっているメッセージにコマンドを制限します。
      パラメーター:
      minIdleTime - null であってはなりません。
      戻り値:
      RedisStreamCommands.XClaimOptions の新しいインスタンス。

    • minIdleMs

      public static RedisStreamCommands.XClaimOptions.XClaimOptionsBuilder minIdleMs(long millis)
      min-idle-time を設定して、コマンドを少なくとも指定されたミリ秒の間アイドル状態になっているメッセージに制限します。
      パラメーター:
      millis -
      戻り値:
      RedisStreamCommands.XClaimOptions の新しいインスタンス。

    • idle

      public RedisStreamCommands.XClaimOptions idle(DurationSE idleTime)
      メッセージが最後に配信されてからのアイドル時間を設定します。特定の時点を指定するには、time(Instant) を使用します。
      パラメーター:
      idleTime - アイドル時間。
      戻り値:
      this.

    • time

      public RedisStreamCommands.XClaimOptions time(InstantSE unixTime)
      アイドル時間を特定の UNIX 時間（ミリ秒単位）に設定します。相対アイドル時間を定義するには、idle(Duration) を使用します。
      パラメーター:
      unixTime - アイドル時間。
      戻り値:
      this.

    • retryCount

      public RedisStreamCommands.XClaimOptions retryCount(long retryCount)
      再試行カウンターを指定された値に設定します。
      パラメーター:
      retryCount - null にすることができます。null の場合、再試行カウンターは変更されません。
      戻り値:
      RedisStreamCommands.XClaimOptions の新しいインスタンス。

    • force

      public RedisStreamCommands.XClaimOptions force()
      指定されたストリームレコード ID が有効である限り、保留中のメッセージエントリがまだ存在していなくても、強制的に PEL に作成されます。
      戻り値:
      RedisStreamCommands.XClaimOptions の新しいインスタンス。

    • getIds

      public ListSE<RecordId> getIds()
      ID の ListSE を取得します。
      戻り値:
      決して null にはなりません。

    • getIdsAsStringArray

      public StringSE[] getIdsAsStringArray()
      ID 配列を stringsSE として取得します。
      戻り値:
      決して null にはなりません。

    • getMinIdleTime

      public DurationSE getMinIdleTime()
      最小アイドル時間を取得します。
      戻り値:
      決して null にはなりません。

    • getIdleTime

      @Nullable public DurationSE getIdleTime()
      IDLE ミリ秒時間を取得します。
      戻り値:
      null でもかまいません。

    • getUnixTime

      @Nullable public InstantSE getUnixTime()
      時間を取得する ms-unix-time
      戻り値:

    • getRetryCount

      @Nullable public LongSE getRetryCount()
      RETRYCOUNT カウントを取得します。
      戻り値:

    • isForce

      public boolean isForce()
      FORCE フラグを取得します。
      戻り値: