| Package | Description |
|---|---|
| io.lettuce.core |
The Redis client package containing
RedisClient for Redis Standalone and Redis Sentinel operations. |
| io.lettuce.core.api.async |
Standalone Redis API for asynchronous executed commands.
|
| io.lettuce.core.api.reactive |
Standalone Redis API for reactive command execution.
|
| io.lettuce.core.api.sync |
Standalone Redis API for synchronous executed commands.
|
| io.lettuce.core.cluster.api.async |
Redis Cluster API for asynchronous executed commands.
|
| io.lettuce.core.cluster.api.sync |
Redis Cluster API for synchronous executed commands.
|
| Modifier and Type | Method and Description |
|---|---|
static XNackMode |
XNackMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static XNackMode[] |
XNackMode.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
RedisFuture<Long> |
AbstractRedisAsyncCommands.xnack(K key,
K group,
XNackMode mode,
String... messageIds) |
reactor.core.publisher.Mono<Long> |
AbstractRedisReactiveCommands.xnack(K key,
K group,
XNackMode mode,
String... messageIds) |
RedisFuture<Long> |
AbstractRedisAsyncCommands.xnack(K key,
K group,
XNackMode mode,
String messageId) |
reactor.core.publisher.Mono<Long> |
AbstractRedisReactiveCommands.xnack(K key,
K group,
XNackMode mode,
String messageId) |
| Modifier and Type | Method and Description |
|---|---|
RedisFuture<Long> |
RedisStreamAsyncCommands.xnack(K key,
K group,
XNackMode mode,
String... messageIds)
Negatively acknowledge one or more pending messages in a consumer group, making them immediately available for
reconsumption by other consumers (using
XREADGROUP CLAIM). |
RedisFuture<Long> |
RedisStreamAsyncCommands.xnack(K key,
K group,
XNackMode mode,
String messageId)
Negatively acknowledge a single pending message in a consumer group, making it immediately available for reconsumption by
other consumers (using
XREADGROUP CLAIM). |
| Modifier and Type | Method and Description |
|---|---|
reactor.core.publisher.Mono<Long> |
RedisStreamReactiveCommands.xnack(K key,
K group,
XNackMode mode,
String... messageIds)
Negatively acknowledge one or more pending messages in a consumer group, making them immediately available for
reconsumption by other consumers (using
XREADGROUP CLAIM). |
reactor.core.publisher.Mono<Long> |
RedisStreamReactiveCommands.xnack(K key,
K group,
XNackMode mode,
String messageId)
Negatively acknowledge a single pending message in a consumer group, making it immediately available for reconsumption by
other consumers (using
XREADGROUP CLAIM). |
| Modifier and Type | Method and Description |
|---|---|
Long |
RedisStreamCommands.xnack(K key,
K group,
XNackMode mode,
String... messageIds)
Negatively acknowledge one or more pending messages in a consumer group, making them immediately available for
reconsumption by other consumers (using
XREADGROUP CLAIM). |
Long |
RedisStreamCommands.xnack(K key,
K group,
XNackMode mode,
String messageId)
Negatively acknowledge a single pending message in a consumer group, making it immediately available for reconsumption by
other consumers (using
XREADGROUP CLAIM). |
| Modifier and Type | Method and Description |
|---|---|
AsyncExecutions<Long> |
NodeSelectionStreamAsyncCommands.xnack(K key,
K group,
XNackMode mode,
String... messageIds)
Negatively acknowledge one or more pending messages in a consumer group, making them immediately available for
reconsumption by other consumers (using
XREADGROUP CLAIM). |
AsyncExecutions<Long> |
NodeSelectionStreamAsyncCommands.xnack(K key,
K group,
XNackMode mode,
String messageId)
Negatively acknowledge a single pending message in a consumer group, making it immediately available for reconsumption by
other consumers (using
XREADGROUP CLAIM). |
| Modifier and Type | Method and Description |
|---|---|
Executions<Long> |
NodeSelectionStreamCommands.xnack(K key,
K group,
XNackMode mode,
String... messageIds)
Negatively acknowledge one or more pending messages in a consumer group, making them immediately available for
reconsumption by other consumers (using
XREADGROUP CLAIM). |
Executions<Long> |
NodeSelectionStreamCommands.xnack(K key,
K group,
XNackMode mode,
String messageId)
Negatively acknowledge a single pending message in a consumer group, making it immediately available for reconsumption by
other consumers (using
XREADGROUP CLAIM). |
Copyright © 2026 lettuce.io. All rights reserved.