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 |
---|---|
XReadArgs |
XReadArgs.block(Duration timeout)
Perform a blocking read and wait up to a
timeout for a new stream message. |
static XReadArgs |
XReadArgs.Builder.block(Duration timeout)
Create a new
XReadArgs and set BLOCK. |
XReadArgs |
XReadArgs.block(long milliseconds)
Perform a blocking read and wait up to
milliseconds for a new stream message. |
static XReadArgs |
XReadArgs.Builder.block(long milliseconds)
Create a new
XReadArgs and set BLOCK. |
XReadArgs |
XReadArgs.count(long count)
Limit read to
count messages. |
static XReadArgs |
XReadArgs.Builder.count(long count)
Create a new
XReadArgs and set COUNT. |
static XReadArgs |
XReadArgs.Builder.noack()
Create a new
XReadArgs and set NOACK. |
XReadArgs |
XReadArgs.noack(boolean noack)
Use NOACK option to disable auto-acknowledgement.
|
static XReadArgs |
XReadArgs.Builder.noack(boolean noack)
Create a new
XReadArgs and set NOACK. |
Modifier and Type | Method and Description |
---|---|
RedisFuture<List<StreamMessage<K,V>>> |
AbstractRedisAsyncCommands.xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams) |
Flux<StreamMessage<K,V>> |
AbstractRedisReactiveCommands.xread(XReadArgs args,
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 args,
XReadArgs.StreamOffset<K>... streams) |
Modifier and Type | Method and Description |
---|---|
RedisFuture<List<StreamMessage<K,V>>> |
RedisStreamAsyncCommands.xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
RedisFuture<List<StreamMessage<K,V>>> |
RedisStreamAsyncCommands.xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Modifier and Type | Method and Description |
---|---|
Flux<StreamMessage<K,V>> |
RedisStreamReactiveCommands.xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
Flux<StreamMessage<K,V>> |
RedisStreamReactiveCommands.xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Modifier and Type | Method and Description |
---|---|
List<StreamMessage<K,V>> |
RedisStreamCommands.xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
List<StreamMessage<K,V>> |
RedisStreamCommands.xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Modifier and Type | Method and Description |
---|---|
AsyncExecutions<List<StreamMessage<K,V>>> |
NodeSelectionStreamAsyncCommands.xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
AsyncExecutions<List<StreamMessage<K,V>>> |
NodeSelectionStreamAsyncCommands.xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Modifier and Type | Method and Description |
---|---|
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Copyright © 2020 lettuce.io. All rights reserved.