クラス ReactiveStreamCommands.PendingRecordsCommand

メソッドの詳細

• range

  public ReactiveStreamCommands.PendingRecordsCommand range(Range<StringSE> range, LongSE count)

  指定された Range と制限を使用して新しい ReactiveStreamCommands.PendingRecordsCommand を作成します。

  戻り値:

  RedisStreamCommands.XPendingOptions の新しいインスタンス。

• consumer

  public ReactiveStreamCommands.PendingRecordsCommand consumer(StringSE consumerName)

  特定のコンシューマーに追加します。

  パラメーター:

  consumerName - null であってはなりません。

  戻り値:

  ReactiveStreamCommands.PendingRecordsCommand の新しいインスタンス。

• getGroupName

  public StringSE getGroupName()

• getConsumerName

  @Nullable public StringSE getConsumerName()

  戻り値:

  null でもかまいません。

• getRange

  public Range<?> getRange()

  戻り値:

  決して null にはなりません。

• getCount

  @Nullable public LongSE getCount()

  戻り値:

  null でもかまいません。

• hasConsumer

  public boolean hasConsumer()

  戻り値:

  コンシューマー名が存在する場合は true。

• isLimited

  public boolean isLimited()

  戻り値:

  真のカウントが設定されます。