Uses of Class
io.lettuce.core.XReadArgs
-
Packages that use XReadArgs 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 XReadArgs in io.lettuce.core
Methods in io.lettuce.core that return XReadArgs Modifier and Type Method Description XReadArgs
XReadArgs. block(long milliseconds)
Perform a blocking read and wait up tomilliseconds
for a new stream message.XReadArgs
XReadArgs. block(Duration timeout)
Perform a blocking read and wait up to atimeout
for a new stream message.static XReadArgs
XReadArgs.Builder. block(long milliseconds)
Create a newXReadArgs
and set BLOCK.static XReadArgs
XReadArgs.Builder. block(Duration timeout)
Create a newXReadArgs
and set BLOCK.static XReadArgs
XReadArgs.Builder. count(long count)
Create a newXReadArgs
and set COUNT.XReadArgs
XReadArgs. count(long count)
Limit read tocount
messages.static XReadArgs
XReadArgs.Builder. noack()
Create a newXReadArgs
and set NOACK.static XReadArgs
XReadArgs.Builder. noack(boolean noack)
Create a newXReadArgs
and set NOACK.XReadArgs
XReadArgs. noack(boolean noack)
Use NOACK option to disable auto-acknowledgement.Methods in io.lettuce.core with parameters of type XReadArgs Modifier and Type Method 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)
-
Uses of XReadArgs in io.lettuce.core.api.async
Methods in io.lettuce.core.api.async with parameters of type XReadArgs Modifier and Type Method Description RedisFuture<List<StreamMessage<K,V>>>
RedisStreamAsyncCommands. xread(XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.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 XReadArgs in io.lettuce.core.api.reactive
Methods in io.lettuce.core.api.reactive with parameters of type XReadArgs Modifier and Type Method Description Flux<StreamMessage<K,V>>
RedisStreamReactiveCommands. xread(XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.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 XReadArgs in io.lettuce.core.api.sync
Methods in io.lettuce.core.api.sync with parameters of type XReadArgs Modifier and Type Method Description List<StreamMessage<K,V>>
RedisStreamCommands. xread(XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.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 XReadArgs in io.lettuce.core.cluster.api.async
Methods in io.lettuce.core.cluster.api.async with parameters of type XReadArgs Modifier and Type Method Description AsyncExecutions<List<StreamMessage<K,V>>>
NodeSelectionStreamAsyncCommands. xread(XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.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 XReadArgs in io.lettuce.core.cluster.api.sync
Methods in io.lettuce.core.cluster.api.sync with parameters of type XReadArgs Modifier and Type Method Description Executions<List<StreamMessage<K,V>>>
NodeSelectionStreamCommands. xread(XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.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.
-