K
- Key type.V
- Value type.public interface NodeSelectionStreamCommands<K,V>
Modifier and Type | Method and Description |
---|---|
Executions<Long> |
xack(K key,
K group,
String... messageIds)
Acknowledge one or more messages as processed.
|
Executions<String> |
xadd(K key,
Map<K,V> body)
Append a message to the stream
key . |
Executions<String> |
xadd(K key,
Object... keysAndValues)
Append a message to the stream
key . |
Executions<String> |
xadd(K key,
XAddArgs args,
Map<K,V> body)
Append a message to the stream
key . |
Executions<String> |
xadd(K key,
XAddArgs args,
Object... keysAndValues)
Append a message to the stream
key . |
Executions<List<StreamMessage<K,V>>> |
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>>> |
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<Long> |
xdel(K key,
String... messageIds)
Removes the specified entries from the stream.
|
Executions<String> |
xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group)
Create a consumer group.
|
Executions<String> |
xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group,
XGroupCreateArgs args)
Create a consumer group.
|
Executions<Boolean> |
xgroupDelconsumer(K key,
Consumer<K> consumer)
Delete a consumer from a consumer group.
|
Executions<Boolean> |
xgroupDestroy(K key,
K group)
Destroy a consumer group.
|
Executions<String> |
xgroupSetid(XReadArgs.StreamOffset<K> streamOffset,
K group)
Set the current
group id. |
Executions<List<Object>> |
xinfoConsumers(K key,
K group)
Retrieve information about consumer groups of group
group and stream at key . |
Executions<List<Object>> |
xinfoGroups(K key)
Retrieve information about the stream consumer groups at
key . |
Executions<List<Object>> |
xinfoStream(K key)
Retrieve information about the stream at
key . |
Executions<Long> |
xlen(K key)
Get the length of a steam.
|
Executions<List<Object>> |
xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
Executions<List<Object>> |
xpending(K key,
K group)
Read pending messages from a stream for a
group . |
Executions<List<Object>> |
xpending(K key,
K group,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
Executions<List<StreamMessage<K,V>>> |
xrange(K key,
Range<String> range)
Read messages from a stream within a specific
Range . |
Executions<List<StreamMessage<K,V>>> |
xrange(K key,
Range<String> range,
Limit limit)
|
Executions<List<StreamMessage<K,V>>> |
xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
Executions<List<StreamMessage<K,V>>> |
xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
Executions<List<StreamMessage<K,V>>> |
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>>> |
xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Executions<List<StreamMessage<K,V>>> |
xrevrange(K key,
Range<String> range)
Read messages from a stream within a specific
Range in reverse order. |
Executions<List<StreamMessage<K,V>>> |
xrevrange(K key,
Range<String> range,
Limit limit)
|
Executions<Long> |
xtrim(K key,
boolean approximateTrimming,
long count)
Trims the stream to
count elements. |
Executions<Long> |
xtrim(K key,
long count)
Trims the stream to
count elements. |
Executions<Long> xack(K key, K group, String... messageIds)
key
- the stream key.group
- name of the consumer group.messageIds
- message Id's to acknowledge.Executions<String> xadd(K key, Map<K,V> body)
key
.key
- the stream key.body
- message body.Executions<String> xadd(K key, XAddArgs args, Map<K,V> body)
key
.key
- the stream key.args
- body
- message body.Executions<String> xadd(K key, Object... keysAndValues)
key
.key
- the stream key.keysAndValues
- message body.Executions<String> xadd(K key, XAddArgs args, Object... keysAndValues)
key
.key
- the stream key.args
- keysAndValues
- message body.Executions<List<StreamMessage<K,V>>> xclaim(K key, Consumer<K> consumer, long minIdleTime, String... messageIds)
key
- the stream key.consumer
- consumer identified by group name and consumer key.minIdleTime
- messageIds
- message Id's to claim.StreamMessage
Executions<List<StreamMessage<K,V>>> xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
key
- the stream key.consumer
- consumer identified by group name and consumer key.args
- messageIds
- message Id's to claim.StreamMessage
Executions<Long> xdel(K key, String... messageIds)
key
- the stream key.messageIds
- stream message Id's.Executions<String> xgroupCreate(XReadArgs.StreamOffset<K> streamOffset, K group)
streamOffset
- name of the stream containing the offset to set.group
- name of the consumer group.Executions<String> xgroupCreate(XReadArgs.StreamOffset<K> streamOffset, K group, XGroupCreateArgs args)
streamOffset
- name of the stream containing the offset to set.group
- name of the consumer group.args
- Executions<Boolean> xgroupDelconsumer(K key, Consumer<K> consumer)
key
- the stream key.consumer
- consumer identified by group name and consumer key.Executions<Boolean> xgroupDestroy(K key, K group)
key
- the stream key.group
- name of the consumer group.Executions<String> xgroupSetid(XReadArgs.StreamOffset<K> streamOffset, K group)
group
id.streamOffset
- name of the stream containing the offset to set.group
- name of the consumer group.Executions<List<Object>> xinfoStream(K key)
key
.key
- the stream key.Executions<List<Object>> xinfoGroups(K key)
key
.key
- the stream key.Executions<List<Object>> xinfoConsumers(K key, K group)
group
and stream at key
.key
- the stream key.group
- name of the consumer group.Executions<Long> xlen(K key)
key
- the stream key.Executions<List<Object>> xpending(K key, K group)
group
.key
- the stream key.group
- name of the consumer group.Executions<List<Object>> xpending(K key, K group, Range<String> range, Limit limit)
Range
.key
- the stream key.group
- name of the consumer group.range
- must not be null.limit
- must not be null.Executions<List<Object>> xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
Range
.key
- the stream key.consumer
- consumer identified by group name and consumer key.range
- must not be null.limit
- must not be null.Executions<List<StreamMessage<K,V>>> xrange(K key, Range<String> range)
Range
.key
- the stream key.range
- must not be null.Executions<List<StreamMessage<K,V>>> xrange(K key, Range<String> range, Limit limit)
key
- the stream key.range
- must not be null.limit
- must not be null.Executions<List<StreamMessage<K,V>>> xread(XReadArgs.StreamOffset<K>... streams)
XReadArgs.StreamOffset
s.streams
- the streams to read from.Executions<List<StreamMessage<K,V>>> xread(XReadArgs args, XReadArgs.StreamOffset<K>... streams)
XReadArgs.StreamOffset
s.args
- read arguments.streams
- the streams to read from.Executions<List<StreamMessage<K,V>>> xreadgroup(Consumer<K> consumer, XReadArgs.StreamOffset<K>... streams)
XReadArgs.StreamOffset
s using a consumer group.consumer
- consumer/group.streams
- the streams to read from.Executions<List<StreamMessage<K,V>>> xreadgroup(Consumer<K> consumer, XReadArgs args, XReadArgs.StreamOffset<K>... streams)
XReadArgs.StreamOffset
s using a consumer group.consumer
- consumer/group.args
- read arguments.streams
- the streams to read from.Executions<List<StreamMessage<K,V>>> xrevrange(K key, Range<String> range)
Range
in reverse order.key
- the stream key.range
- must not be null.Executions<List<StreamMessage<K,V>>> xrevrange(K key, Range<String> range, Limit limit)
key
- the stream key.range
- must not be null.limit
- must not be null.Executions<Long> xtrim(K key, long count)
count
elements.key
- the stream key.count
- length of the stream.Executions<Long> xtrim(K key, boolean approximateTrimming, long count)
count
elements.key
- the stream key.approximateTrimming
- true to trim approximately using the ~
flag.count
- length of the stream.Copyright © 2019 lettuce.io. All rights reserved.