Uses of Class
org.springframework.data.redis.connection.RedisStreamCommands.XClaimOptions

Packages that use RedisStreamCommands.XClaimOptions

Package	Description
org.springframework.data.redis.connection	Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
org.springframework.data.redis.core	Core package for integrating Redis with Spring concepts.

Uses of RedisStreamCommands.XClaimOptions in org.springframework.data.redis.connection

Methods in org.springframework.data.redis.connection that return RedisStreamCommands.XClaimOptions

Modifier and Type	Method and Description
RedisStreamCommands.XClaimOptions	RedisStreamCommands.XClaimOptions.force() Forces creation of a pending message entry in the PEL even if it does not already exist as long a the given stream record id is valid.
RedisStreamCommands.XClaimOptions	ReactiveStreamCommands.XClaimCommand.getOptions()
RedisStreamCommands.XClaimOptions	RedisStreamCommands.XClaimOptions.idle(Duration idleTime) Set the idle time since last delivery of a message.
RedisStreamCommands.XClaimOptions	RedisStreamCommands.XClaimOptions.XClaimOptionsBuilder.ids(List<?> ids) Set the IDs to claim.
RedisStreamCommands.XClaimOptions	RedisStreamCommands.XClaimOptions.XClaimOptionsBuilder.ids(RecordId... ids) Set the IDs to claim.
RedisStreamCommands.XClaimOptions	RedisStreamCommands.XClaimOptions.XClaimOptionsBuilder.ids(String... ids) Set the IDs to claim.
RedisStreamCommands.XClaimOptions	RedisStreamCommands.XClaimOptions.retryCount(long retryCount) Set the retry counter to the specified value.
RedisStreamCommands.XClaimOptions	RedisStreamCommands.XClaimOptions.time(Instant unixTime) Sets the idle time to a specific unix time (in milliseconds).

Methods in org.springframework.data.redis.connection with parameters of type RedisStreamCommands.XClaimOptions

Modifier and Type	Method and Description
List<ByteRecord>	RedisStreamCommands.xClaim(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer.
List<ByteRecord>	DefaultStringRedisConnection.xClaim(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options)
default List<ByteRecord>	DefaultedRedisConnection.xClaim(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Deprecated. in favor of RedisConnection.streamCommands()}.
default reactor.core.publisher.Flux<ByteBufferRecord>	ReactiveStreamCommands.xClaim(ByteBuffer key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer.
List<StringRecord>	StringRedisConnection.xClaim(String key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer.
List<StringRecord>	DefaultStringRedisConnection.xClaim(String key, String group, String consumer, RedisStreamCommands.XClaimOptions options)
List<RecordId>	RedisStreamCommands.xClaimJustId(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer without increasing the delivered count.
List<RecordId>	DefaultStringRedisConnection.xClaimJustId(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options)
default List<RecordId>	DefaultedRedisConnection.xClaimJustId(byte[] key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Deprecated. in favor of RedisConnection.streamCommands()}.
default reactor.core.publisher.Flux<RecordId>	ReactiveStreamCommands.xClaimJustId(ByteBuffer key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer without increasing the delivered count.
List<RecordId>	StringRedisConnection.xClaimJustId(String key, String group, String newOwner, RedisStreamCommands.XClaimOptions options) Change the ownership of a pending message to the given new consumer without increasing the delivered count.
List<RecordId>	DefaultStringRedisConnection.xClaimJustId(String key, String group, String consumer, RedisStreamCommands.XClaimOptions options)

Uses of RedisStreamCommands.XClaimOptions in org.springframework.data.redis.core

Methods in org.springframework.data.redis.core with parameters of type RedisStreamCommands.XClaimOptions

Modifier and Type	Method and Description
reactor.core.publisher.Flux<MapRecord<K,HK,HV>>	ReactiveStreamOperations.claim(K key, String consumerGroup, String newOwner, RedisStreamCommands.XClaimOptions xClaimOptions) Changes the ownership of a pending message so that the new owner is the consumer specified as the command argument.
List<MapRecord<K,HK,HV>>	StreamOperations.claim(K key, String consumerGroup, String newOwner, RedisStreamCommands.XClaimOptions xClaimOptions) Changes the ownership of a pending message so that the new owner is the consumer specified as the command argument.