public static class ReactiveStreamCommands.PendingRecordsCommand extends ReactiveRedisConnection.KeyCommand
Modifier and Type | Method and Description |
---|---|
ReactiveStreamCommands.PendingRecordsCommand |
consumer(String consumerName)
Append given consumer.
|
String |
getConsumerName() |
Long |
getCount() |
String |
getGroupName() |
Range<?> |
getRange() |
boolean |
hasConsumer() |
boolean |
isLimited() |
ReactiveStreamCommands.PendingRecordsCommand |
range(Range<String> range,
Long count)
Create new
ReactiveStreamCommands.PendingRecordsCommand with given Range and limit. |
getKey
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getName
public ReactiveStreamCommands.PendingRecordsCommand range(Range<String> range, Long count)
ReactiveStreamCommands.PendingRecordsCommand
with given Range
and limit.RedisStreamCommands.XPendingOptions
.public ReactiveStreamCommands.PendingRecordsCommand consumer(String consumerName)
consumerName
- must not be null.ReactiveStreamCommands.PendingRecordsCommand
.public String getGroupName()
public Range<?> getRange()
public boolean hasConsumer()
public boolean isLimited()
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.