Class ReactiveStreamCommands.PendingRecordsCommand
java.lang.Object
org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand
org.springframework.data.redis.connection.ReactiveStreamCommands.PendingRecordsCommand
- All Implemented Interfaces:
ReactiveRedisConnection.Command
- Enclosing interface:
- ReactiveStreamCommands
public static class ReactiveStreamCommands.PendingRecordsCommand
extends ReactiveRedisConnection.KeyCommand
Value Object holding parameters for obtaining pending messages.
- Since:
- 2.3
- Author:
- Christoph Strobl
-
Method Summary
Modifier and TypeMethodDescriptionAppend given consumer.getCount()
Range<?>
getRange()
boolean
boolean
Create newReactiveStreamCommands.PendingRecordsCommand
with givenRange
and limit.Methods inherited from class org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand
getKey
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.data.redis.connection.ReactiveRedisConnection.Command
getName
-
Method Details
-
range
Create newReactiveStreamCommands.PendingRecordsCommand
with givenRange
and limit.- Parameters:
range
- must not be null.count
- the max number of messages to return. Must not be negative.- Returns:
- new instance of
RedisStreamCommands.XPendingOptions
.
-
consumer
Append given consumer.- Parameters:
consumerName
- must not be null.- Returns:
- new instance of
ReactiveStreamCommands.PendingRecordsCommand
.
-
getGroupName
-
getConsumerName
- Returns:
- can be null.
-
getRange
- Returns:
- never null.
-
getCount
- Returns:
- can be null.
-
hasConsumer
public boolean hasConsumer()- Returns:
- true if a consumer name is present.
-
isLimited
public boolean isLimited()- Returns:
- true count is set.
-