Uses of Class
io.lettuce.core.StreamMessage
-
Packages that use StreamMessage 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.io.lettuce.core.models.stream Model and parser for the Stream-related command output such as XPENDING.io.lettuce.core.output Implementation of different output protocols including the Streaming API. -
-
Uses of StreamMessage in io.lettuce.core
Methods in io.lettuce.core that return types with arguments of type StreamMessage Modifier and Type Method Description 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<List<StreamMessage<K,V>>>
AbstractRedisAsyncCommands. xrange(K key, Range<String> range)
RedisFuture<List<StreamMessage<K,V>>>
AbstractRedisAsyncCommands. xrange(K key, Range<String> range, Limit limit)
Flux<StreamMessage<K,V>>
AbstractRedisReactiveCommands. xrange(K key, Range<String> range)
Flux<StreamMessage<K,V>>
AbstractRedisReactiveCommands. xrange(K key, Range<String> range, Limit limit)
RedisFuture<List<StreamMessage<K,V>>>
AbstractRedisAsyncCommands. xread(XReadArgs.StreamOffset<K>... streams)
RedisFuture<List<StreamMessage<K,V>>>
AbstractRedisAsyncCommands. xread(XReadArgs args, XReadArgs.StreamOffset<K>... streams)
Flux<StreamMessage<K,V>>
AbstractRedisReactiveCommands. xread(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.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)
RedisFuture<List<StreamMessage<K,V>>>
AbstractRedisAsyncCommands. xrevrange(K key, Range<String> range)
RedisFuture<List<StreamMessage<K,V>>>
AbstractRedisAsyncCommands. xrevrange(K key, Range<String> range, Limit limit)
Flux<StreamMessage<K,V>>
AbstractRedisReactiveCommands. xrevrange(K key, Range<String> range)
Flux<StreamMessage<K,V>>
AbstractRedisReactiveCommands. xrevrange(K key, Range<String> range, Limit limit)
-
Uses of StreamMessage in io.lettuce.core.api.async
Methods in io.lettuce.core.api.async that return types with arguments of type StreamMessage 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<List<StreamMessage<K,V>>>
RedisStreamAsyncCommands. xrange(K key, Range<String> range)
Read messages from a stream within a specificRange
.RedisFuture<List<StreamMessage<K,V>>>
RedisStreamAsyncCommands. xrange(K key, Range<String> range, Limit limit)
RedisFuture<List<StreamMessage<K,V>>>
RedisStreamAsyncCommands. xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.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.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.RedisFuture<List<StreamMessage<K,V>>>
RedisStreamAsyncCommands. xrevrange(K key, Range<String> range)
Read messages from a stream within a specificRange
in reverse order.RedisFuture<List<StreamMessage<K,V>>>
RedisStreamAsyncCommands. xrevrange(K key, Range<String> range, Limit limit)
-
Uses of StreamMessage in io.lettuce.core.api.reactive
Methods in io.lettuce.core.api.reactive that return types with arguments of type StreamMessage 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.Flux<StreamMessage<K,V>>
RedisStreamReactiveCommands. xrange(K key, Range<String> range)
Read messages from a stream within a specificRange
.Flux<StreamMessage<K,V>>
RedisStreamReactiveCommands. xrange(K key, Range<String> range, Limit limit)
Flux<StreamMessage<K,V>>
RedisStreamReactiveCommands. xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.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.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.Flux<StreamMessage<K,V>>
RedisStreamReactiveCommands. xrevrange(K key, Range<String> range)
Read messages from a stream within a specificRange
in reverse order.Flux<StreamMessage<K,V>>
RedisStreamReactiveCommands. xrevrange(K key, Range<String> range, Limit limit)
-
Uses of StreamMessage in io.lettuce.core.api.sync
Methods in io.lettuce.core.api.sync that return types with arguments of type StreamMessage 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.List<StreamMessage<K,V>>
RedisStreamCommands. xrange(K key, Range<String> range)
Read messages from a stream within a specificRange
.List<StreamMessage<K,V>>
RedisStreamCommands. xrange(K key, Range<String> range, Limit limit)
List<StreamMessage<K,V>>
RedisStreamCommands. xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.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.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.List<StreamMessage<K,V>>
RedisStreamCommands. xrevrange(K key, Range<String> range)
Read messages from a stream within a specificRange
in reverse order.List<StreamMessage<K,V>>
RedisStreamCommands. xrevrange(K key, Range<String> range, Limit limit)
-
Uses of StreamMessage in io.lettuce.core.cluster.api.async
Methods in io.lettuce.core.cluster.api.async that return types with arguments of type StreamMessage 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<List<StreamMessage<K,V>>>
NodeSelectionStreamAsyncCommands. xrange(K key, Range<String> range)
Read messages from a stream within a specificRange
.AsyncExecutions<List<StreamMessage<K,V>>>
NodeSelectionStreamAsyncCommands. xrange(K key, Range<String> range, Limit limit)
AsyncExecutions<List<StreamMessage<K,V>>>
NodeSelectionStreamAsyncCommands. xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.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.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.AsyncExecutions<List<StreamMessage<K,V>>>
NodeSelectionStreamAsyncCommands. xrevrange(K key, Range<String> range)
Read messages from a stream within a specificRange
in reverse order.AsyncExecutions<List<StreamMessage<K,V>>>
NodeSelectionStreamAsyncCommands. xrevrange(K key, Range<String> range, Limit limit)
-
Uses of StreamMessage in io.lettuce.core.cluster.api.sync
Methods in io.lettuce.core.cluster.api.sync that return types with arguments of type StreamMessage 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<List<StreamMessage<K,V>>>
NodeSelectionStreamCommands. xrange(K key, Range<String> range)
Read messages from a stream within a specificRange
.Executions<List<StreamMessage<K,V>>>
NodeSelectionStreamCommands. xrange(K key, Range<String> range, Limit limit)
Executions<List<StreamMessage<K,V>>>
NodeSelectionStreamCommands. xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or moreXReadArgs.StreamOffset
s.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.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.Executions<List<StreamMessage<K,V>>>
NodeSelectionStreamCommands. xrevrange(K key, Range<String> range)
Read messages from a stream within a specificRange
in reverse order.Executions<List<StreamMessage<K,V>>>
NodeSelectionStreamCommands. xrevrange(K key, Range<String> range, Limit limit)
-
Uses of StreamMessage in io.lettuce.core.models.stream
Methods in io.lettuce.core.models.stream that return types with arguments of type StreamMessage Modifier and Type Method Description List<StreamMessage<K,V>>
ClaimedMessages. getMessages()
Constructor parameters in io.lettuce.core.models.stream with type arguments of type StreamMessage Constructor Description ClaimedMessages(String id, List<StreamMessage<K,V>> messages)
Create a newClaimedMessages
. -
Uses of StreamMessage in io.lettuce.core.output
Methods in io.lettuce.core.output that return types with arguments of type StreamMessage Modifier and Type Method Description StreamingOutput.Subscriber<StreamMessage<K,V>>
StreamMessageListOutput. getSubscriber()
StreamingOutput.Subscriber<StreamMessage<K,V>>
StreamReadOutput. getSubscriber()
Method parameters in io.lettuce.core.output with type arguments of type StreamMessage Modifier and Type Method Description void
StreamMessageListOutput. setSubscriber(StreamingOutput.Subscriber<StreamMessage<K,V>> subscriber)
void
StreamReadOutput. setSubscriber(StreamingOutput.Subscriber<StreamMessage<K,V>> subscriber)
-