Package org.springframework.data.redis.connection

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 Type	Method	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.

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

public ReactiveStreamCommands.PendingRecordsCommand range(Range<String> range,
 Long count)

Create new ReactiveStreamCommands.PendingRecordsCommand with given Range and limit.

Returns:

new instance of RedisStreamCommands.XPendingOptions.

consumer

public ReactiveStreamCommands.PendingRecordsCommand consumer(String consumerName)

Append given consumer.

Parameters:

consumerName - must not be null.

Returns:

new instance of ReactiveStreamCommands.PendingRecordsCommand.

getGroupName

public String getGroupName()

getConsumerName

@Nullable
public String getConsumerName()

Returns:

can be null.

getRange

public Range<?> getRange()

Returns:

never null.

getCount

@Nullable
public Long 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.