Package | Description |
---|---|
com.lambdaworks.redis |
The redis client package containing
RedisClient for regular and sentinel operations. |
com.lambdaworks.redis.api.async |
Standalone Redis API for asynchronous executed commands.
|
com.lambdaworks.redis.api.rx |
Standalone Redis API for reactive commands.
|
com.lambdaworks.redis.api.sync |
Standalone Redis API for synchronous executed commands.
|
com.lambdaworks.redis.cluster.api.async |
Redis Cluster API for asynchronous executed commands.
|
com.lambdaworks.redis.cluster.api.sync |
Redis Cluster API for synchronous executed commands.
|
Modifier and Type | Method and Description |
---|---|
static <K> Consumer<K> |
Consumer.from(K group,
K name)
Create a new consumer.
|
Modifier and Type | Method and Description |
---|---|
RedisFuture<List<StreamMessage<K,V>>> |
AbstractRedisAsyncCommands.xclaim(K key,
Consumer<K> consumer,
long minIdleTime,
String... messageIds) |
Observable<StreamMessage<K,V>> |
AbstractRedisReactiveCommands.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) |
Observable<StreamMessage<K,V>> |
AbstractRedisReactiveCommands.xclaim(K key,
Consumer<K> consumer,
XClaimArgs args,
String... messageIds) |
RedisFuture<Boolean> |
AbstractRedisAsyncCommands.xgroupDelconsumer(K key,
Consumer<K> consumer) |
Observable<Boolean> |
AbstractRedisReactiveCommands.xgroupDelconsumer(K key,
Consumer<K> consumer) |
RedisFuture<List<Object>> |
AbstractRedisAsyncCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit) |
Observable<Object> |
AbstractRedisReactiveCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit) |
RedisFuture<List<StreamMessage<K,V>>> |
AbstractRedisAsyncCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams) |
Observable<StreamMessage<K,V>> |
AbstractRedisReactiveCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams) |
RedisFuture<List<StreamMessage<K,V>>> |
AbstractRedisAsyncCommands.xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams) |
Observable<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.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.xgroupDelconsumer(K key,
Consumer<K> consumer)
Delete a consumer from a consumer group.
|
RedisFuture<List<Object>> |
RedisStreamAsyncCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
RedisFuture<List<StreamMessage<K,V>>> |
RedisStreamAsyncCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.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 more
XReadArgs.StreamOffset s using a consumer group. |
Modifier and Type | Method and Description |
---|---|
Observable<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.
|
Observable<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.
|
Observable<Boolean> |
RedisStreamReactiveCommands.xgroupDelconsumer(K key,
Consumer<K> consumer)
Delete a consumer from a consumer group.
|
Observable<Object> |
RedisStreamReactiveCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
Observable<StreamMessage<K,V>> |
RedisStreamReactiveCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Observable<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.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.xgroupDelconsumer(K key,
Consumer<K> consumer)
Delete a consumer from a consumer group.
|
List<Object> |
RedisStreamCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
List<StreamMessage<K,V>> |
RedisStreamCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.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 more
XReadArgs.StreamOffset s using a consumer group. |
Modifier and Type | Method and 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.xgroupDelconsumer(K key,
Consumer<K> consumer)
Delete a consumer from a consumer group.
|
AsyncExecutions<List<Object>> |
NodeSelectionStreamAsyncCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
AsyncExecutions<List<StreamMessage<K,V>>> |
NodeSelectionStreamAsyncCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.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 more
XReadArgs.StreamOffset s using a consumer group. |
Modifier and Type | Method and 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.xgroupDelconsumer(K key,
Consumer<K> consumer)
Delete a consumer from a consumer group.
|
Executions<List<Object>> |
NodeSelectionStreamCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.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 more
XReadArgs.StreamOffset s using a consumer group. |
Copyright © 2018 lettuce.io. All rights reserved.