Uses of Class
io.lettuce.core.Consumer
-
Packages that use Consumer Package Description io.lettuce.core The Redis client package containingRedisClient
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. -
-
Uses of Consumer in io.lettuce.core
Methods in io.lettuce.core that return Consumer Modifier and Type Method Description static <K> Consumer<K>
Consumer. from(K group, K name)
Create a new consumer.Methods in io.lettuce.core with parameters of type Consumer Modifier and Type Method Description XAutoClaimArgs<K>
XAutoClaimArgs. consumer(Consumer<K> consumer)
Configure theConsumer
.XPendingArgs<K>
XPendingArgs. consumer(Consumer<K> consumer)
static <K> XAutoClaimArgs<K>
XAutoClaimArgs.Builder. justid(Consumer<K> consumer, long minIdleTime, String startId)
Creates newXAutoClaimArgs
and set theJUSTID
flag to return just the message id and do not increment the retry counter.static <K> XAutoClaimArgs<K>
XAutoClaimArgs.Builder. justid(Consumer<K> consumer, Duration minIdleTime, String startId)
Creates newXAutoClaimArgs
and set theJUSTID
flag to return just the message id and do not increment the retry counter.static <K> XAutoClaimArgs<K>
XAutoClaimArgs.Builder. xautoclaim(Consumer<K> consumer, long minIdleTime, String startId)
Creates newXAutoClaimArgs
.static <K> XAutoClaimArgs<K>
XAutoClaimArgs.Builder. xautoclaim(Consumer<K> consumer, Duration minIdleTime, String startId)
Creates newXAutoClaimArgs
.RedisFuture<List<StreamMessage<K,V>>>
AbstractRedisAsyncCommands. xclaim(K key, Consumer<K> consumer, long minIdleTime, String... messageIds)
RedisFuture<List<StreamMessage<K,V>>>
AbstractRedisAsyncCommands. xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
Flux<StreamMessage<K,V>>
AbstractRedisReactiveCommands. xclaim(K key, Consumer<K> consumer, long minIdleTime, String... messageIds)
Flux<StreamMessage<K,V>>
AbstractRedisReactiveCommands. xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
RedisFuture<Boolean>
AbstractRedisAsyncCommands. xgroupCreateconsumer(K key, Consumer<K> consumer)
Mono<Boolean>
AbstractRedisReactiveCommands. xgroupCreateconsumer(K key, Consumer<K> consumer)
RedisFuture<Long>
AbstractRedisAsyncCommands. xgroupDelconsumer(K key, Consumer<K> consumer)
Mono<Long>
AbstractRedisReactiveCommands. xgroupDelconsumer(K key, Consumer<K> consumer)
RedisFuture<List<PendingMessage>>
AbstractRedisAsyncCommands. xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
Flux<PendingMessage>
AbstractRedisReactiveCommands. xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
static <K> XPendingArgs<K>
XPendingArgs.Builder. xpending(Consumer<K> consumer, Range<String> range, Limit limit)
Create a newXPendingArgs
.RedisFuture<List<StreamMessage<K,V>>>
AbstractRedisAsyncCommands. xreadgroup(Consumer<K> consumer, XReadArgs.StreamOffset<K>... streams)
RedisFuture<List<StreamMessage<K,V>>>
AbstractRedisAsyncCommands. xreadgroup(Consumer<K> consumer, XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Flux<StreamMessage<K,V>>
AbstractRedisReactiveCommands. xreadgroup(Consumer<K> consumer, XReadArgs.StreamOffset<K>... streams)
Flux<StreamMessage<K,V>>
AbstractRedisReactiveCommands. xreadgroup(Consumer<K> consumer, XReadArgs args, XReadArgs.StreamOffset<K>... streams)
-
Uses of Consumer in io.lettuce.core.api.async
Methods in io.lettuce.core.api.async with parameters of type Consumer Modifier and Type Method Description RedisFuture<List<StreamMessage<K,V>>>
RedisStreamAsyncCommands. xclaim(K key, Consumer<K> consumer, long minIdleTime, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.RedisFuture<List<StreamMessage<K,V>>>
RedisStreamAsyncCommands. xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.RedisFuture<Boolean>
RedisStreamAsyncCommands. xgroupCreateconsumer(K key, Consumer<K> consumer)
Create a consumer from a consumer group.RedisFuture<Long>
RedisStreamAsyncCommands. xgroupDelconsumer(K key, Consumer<K> consumer)
Delete a consumer from a consumer group.RedisFuture<List<PendingMessage>>
RedisStreamAsyncCommands. xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
.RedisFuture<List<StreamMessage<K,V>>>
RedisStreamAsyncCommands. xreadgroup(Consumer<K> consumer, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s using a consumer group.RedisFuture<List<StreamMessage<K,V>>>
RedisStreamAsyncCommands. xreadgroup(Consumer<K> consumer, XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s using a consumer group. -
Uses of Consumer in io.lettuce.core.api.reactive
Methods in io.lettuce.core.api.reactive with parameters of type Consumer Modifier and Type Method Description Flux<StreamMessage<K,V>>
RedisStreamReactiveCommands. xclaim(K key, Consumer<K> consumer, long minIdleTime, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.Flux<StreamMessage<K,V>>
RedisStreamReactiveCommands. xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.Mono<Boolean>
RedisStreamReactiveCommands. xgroupCreateconsumer(K key, Consumer<K> consumer)
Create a consumer from a consumer group.Mono<Long>
RedisStreamReactiveCommands. xgroupDelconsumer(K key, Consumer<K> consumer)
Delete a consumer from a consumer group.Flux<PendingMessage>
RedisStreamReactiveCommands. xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
.Flux<StreamMessage<K,V>>
RedisStreamReactiveCommands. xreadgroup(Consumer<K> consumer, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s using a consumer group.Flux<StreamMessage<K,V>>
RedisStreamReactiveCommands. xreadgroup(Consumer<K> consumer, XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s using a consumer group. -
Uses of Consumer in io.lettuce.core.api.sync
Methods in io.lettuce.core.api.sync with parameters of type Consumer Modifier and Type Method Description List<StreamMessage<K,V>>
RedisStreamCommands. xclaim(K key, Consumer<K> consumer, long minIdleTime, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.List<StreamMessage<K,V>>
RedisStreamCommands. xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.Boolean
RedisStreamCommands. xgroupCreateconsumer(K key, Consumer<K> consumer)
Create a consumer from a consumer group.Long
RedisStreamCommands. xgroupDelconsumer(K key, Consumer<K> consumer)
Delete a consumer from a consumer group.List<PendingMessage>
RedisStreamCommands. xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
.List<StreamMessage<K,V>>
RedisStreamCommands. xreadgroup(Consumer<K> consumer, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s using a consumer group.List<StreamMessage<K,V>>
RedisStreamCommands. xreadgroup(Consumer<K> consumer, XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s using a consumer group. -
Uses of Consumer in io.lettuce.core.cluster.api.async
Methods in io.lettuce.core.cluster.api.async with parameters of type Consumer Modifier and Type Method Description AsyncExecutions<List<StreamMessage<K,V>>>
NodeSelectionStreamAsyncCommands. xclaim(K key, Consumer<K> consumer, long minIdleTime, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.AsyncExecutions<List<StreamMessage<K,V>>>
NodeSelectionStreamAsyncCommands. xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.AsyncExecutions<Boolean>
NodeSelectionStreamAsyncCommands. xgroupCreateconsumer(K key, Consumer<K> consumer)
Create a consumer from a consumer group.AsyncExecutions<Long>
NodeSelectionStreamAsyncCommands. xgroupDelconsumer(K key, Consumer<K> consumer)
Delete a consumer from a consumer group.AsyncExecutions<List<PendingMessage>>
NodeSelectionStreamAsyncCommands. xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
.AsyncExecutions<List<StreamMessage<K,V>>>
NodeSelectionStreamAsyncCommands. xreadgroup(Consumer<K> consumer, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s using a consumer group.AsyncExecutions<List<StreamMessage<K,V>>>
NodeSelectionStreamAsyncCommands. xreadgroup(Consumer<K> consumer, XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s using a consumer group. -
Uses of Consumer in io.lettuce.core.cluster.api.sync
Methods in io.lettuce.core.cluster.api.sync with parameters of type Consumer Modifier and Type Method Description Executions<List<StreamMessage<K,V>>>
NodeSelectionStreamCommands. xclaim(K key, Consumer<K> consumer, long minIdleTime, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.Executions<List<StreamMessage<K,V>>>
NodeSelectionStreamCommands. xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.Executions<Boolean>
NodeSelectionStreamCommands. xgroupCreateconsumer(K key, Consumer<K> consumer)
Create a consumer from a consumer group.Executions<Long>
NodeSelectionStreamCommands. xgroupDelconsumer(K key, Consumer<K> consumer)
Delete a consumer from a consumer group.Executions<List<PendingMessage>>
NodeSelectionStreamCommands. xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
Read pending messages from a stream within a specificRange
.Executions<List<StreamMessage<K,V>>>
NodeSelectionStreamCommands. xreadgroup(Consumer<K> consumer, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s using a consumer group.Executions<List<StreamMessage<K,V>>>
NodeSelectionStreamCommands. xreadgroup(Consumer<K> consumer, XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s using a consumer group.
-