Package | Description |
---|---|
org.springframework.data.redis.connection |
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
|
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).
|
Modifier and Type | Method and Description |
---|---|
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() }. |
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.
|
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> |
DefaultStringRedisConnection.xClaim(String key,
String group,
String consumer,
RedisStreamCommands.XClaimOptions options) |
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<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() }. |
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.
|
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> |
DefaultStringRedisConnection.xClaimJustId(String key,
String group,
String consumer,
RedisStreamCommands.XClaimOptions options) |
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.
|
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.