public class RedisStreamMethods
extends io.toro.martini.redis.RedisBaseMethods
Constructor and Description |
---|
RedisStreamMethods(DataSourceManager dataSourceManager) |
Modifier and Type | Method and Description |
---|---|
static Long |
xack(String connectionName,
Object key,
Object group,
io.toro.gloop.engine.GloopExecutionContext context,
String... messageIds)
Acknowledge one or more messages as processed.
|
static Future<Long> |
xackAsync(String connectionName,
Object key,
Object group,
io.toro.gloop.engine.GloopExecutionContext context,
String... messageIds)
Asynchronously acknowledge one or more messages as processed.
|
static String |
xadd(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keysAndValues)
Append a message to the stream
key . |
static String |
xadd(String connectionName,
Object key,
io.toro.gloop.object.property.GloopModel redisMap,
io.toro.gloop.engine.GloopExecutionContext context)
Append a message to the stream
key . |
static String |
xadd(String connectionName,
Object key,
XAddArgs args,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keysAndValues)
Append a message to the stream
key . |
static String |
xadd(String connectionName,
Object key,
XAddArgs args,
io.toro.gloop.object.property.GloopModel redisMap,
io.toro.gloop.engine.GloopExecutionContext context)
Append a message to the stream
key . |
static Future<String> |
xaddAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keysAndValues)
Asynchronously append a message to the stream
key . |
static Future<String> |
xaddAsync(String connectionName,
Object key,
io.toro.gloop.object.property.GloopModel redisMap,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously append a message to the stream
key . |
static Future<String> |
xaddAsync(String connectionName,
Object key,
XAddArgs args,
io.toro.gloop.engine.GloopExecutionContext context,
Object... keysAndValues)
Asynchronously append a message to the stream
key . |
static Future<String> |
xaddAsync(String connectionName,
Object key,
XAddArgs args,
io.toro.gloop.object.property.GloopModel redisMap,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously append a message to the stream
key . |
static List<StreamMessage<Object,Object>> |
xclaim(String connectionName,
Object key,
Consumer<Object> consumer,
long minIdleTime,
io.toro.gloop.engine.GloopExecutionContext context,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
static List<StreamMessage<Object,Object>> |
xclaim(String connectionName,
Object key,
Consumer<Object> consumer,
XClaimArgs args,
io.toro.gloop.engine.GloopExecutionContext context,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
static Future<List<StreamMessage<Object,Object>>> |
xclaimAsync(String connectionName,
Object key,
Consumer<Object> consumer,
long minIdleTime,
io.toro.gloop.engine.GloopExecutionContext context,
String... messageIds)
Asynchronously gets ownership of one or multiple messages in the pending entries list of a given stream consumer
group.
|
static Future<List<StreamMessage<Object,Object>>> |
xclaimAsync(String connectionName,
Object key,
Consumer<Object> consumer,
XClaimArgs args,
io.toro.gloop.engine.GloopExecutionContext context,
String... messageIds)
Asynchronously gets ownership of one or multiple messages in the pending entries list of a given stream consumer
group.
|
static Long |
xdel(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context,
String... messageIds)
Removes the specified entries from the stream.
|
static Future<Long> |
xdelAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context,
String... messageIds)
Asynchronously removes the specified entries from the stream.
|
static String |
xgroupCreate(String connectionName,
XReadArgs.StreamOffset<Object> streamOffset,
Object group,
io.toro.gloop.engine.GloopExecutionContext context)
Create a consumer group.
|
static Future<String> |
xgroupCreateAsync(String connectionName,
XReadArgs.StreamOffset<Object> streamOffset,
Object group,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously create a consumer group.
|
static Boolean |
xgroupDelconsumer(String connectionName,
Object key,
Consumer<Object> consumer,
io.toro.gloop.engine.GloopExecutionContext context)
Delete a consumer from a consumer group.
|
static Future<Boolean> |
xgroupDelconsumerAsync(String connectionName,
Object key,
Consumer<Object> consumer,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously delete a consumer from a consumer group.
|
static Boolean |
xgroupDestroy(String connectionName,
Object key,
Object group,
io.toro.gloop.engine.GloopExecutionContext context)
Destroy a consumer group.
|
static Future<Boolean> |
xgroupDestroyAsync(String connectionName,
Object key,
Object group,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously destroy a consumer group.
|
static String |
xgroupSetid(String connectionName,
XReadArgs.StreamOffset<Object> streamOffset,
Object group,
io.toro.gloop.engine.GloopExecutionContext context)
Set the current
group id. |
static Future<String> |
xgroupSetidAsync(String connectionName,
XReadArgs.StreamOffset<Object> streamOffset,
Object group,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously set the current
group id. |
static Long |
xlen(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Get the length of a steam.
|
static Future<Long> |
xlenAsync(String connectionName,
Object key,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously get the length of a steam.
|
static List<Object> |
xpending(String connectionName,
Object key,
Consumer<Object> consumer,
Range<String> range,
Limit limit,
io.toro.gloop.engine.GloopExecutionContext context)
Read pending messages from a stream within a specific
Range . |
static List<Object> |
xpending(String connectionName,
Object key,
Object group,
io.toro.gloop.engine.GloopExecutionContext context)
Read pending messages from a stream for a
group . |
static List<Object> |
xpending(String connectionName,
Object key,
Object group,
Range<String> range,
Limit limit,
io.toro.gloop.engine.GloopExecutionContext context)
Read pending messages from a stream within a specific
Range . |
static Future<List<Object>> |
xpendingAsync(String connectionName,
Object key,
Consumer<Object> consumer,
Range<String> range,
Limit limit,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously read pending messages from a stream within a specific
Range . |
static Future<List<Object>> |
xpendingAsync(String connectionName,
Object key,
Object group,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously read pending messages from a stream for a
group . |
static Future<List<Object>> |
xpendingAsync(String connectionName,
Object key,
Object group,
Range<String> range,
Limit limit,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously read pending messages from a stream within a specific
Range . |
static List<StreamMessage<Object,Object>> |
xrange(String connectionName,
Object key,
Range<String> range,
io.toro.gloop.engine.GloopExecutionContext context)
Read messages from a stream within a specific
Range . |
static List<StreamMessage<Object,Object>> |
xrange(String connectionName,
Object key,
Range<String> range,
Limit limit,
io.toro.gloop.engine.GloopExecutionContext context)
|
static Future<List<StreamMessage<Object,Object>>> |
xrangeAsync(String connectionName,
Object key,
Range<String> range,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously read messages from a stream within a specific
Range . |
static Future<List<StreamMessage<Object,Object>>> |
xrangeAsync(String connectionName,
Object key,
Range<String> range,
Limit limit,
io.toro.gloop.engine.GloopExecutionContext context)
|
static List<StreamMessage<Object,Object>> |
xread(String connectionName,
io.toro.gloop.engine.GloopExecutionContext context,
XReadArgs.StreamOffset<Object>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
static List<StreamMessage<Object,Object>> |
xread(String connectionName,
XReadArgs args,
io.toro.gloop.engine.GloopExecutionContext context,
XReadArgs.StreamOffset<Object>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
static Future<List<StreamMessage<Object,Object>>> |
xreadAsync(String connectionName,
io.toro.gloop.engine.GloopExecutionContext context,
XReadArgs.StreamOffset<Object>... streams)
Asynchronously read messages from one or more
XReadArgs.StreamOffset s. |
static Future<List<StreamMessage<Object,Object>>> |
xreadAsync(String connectionName,
XReadArgs args,
io.toro.gloop.engine.GloopExecutionContext context,
XReadArgs.StreamOffset<Object>... streams)
Asynchronously read messages from one or more
XReadArgs.StreamOffset s. |
static List<StreamMessage<Object,Object>> |
xreadgroup(String connectionName,
Consumer<Object> consumer,
io.toro.gloop.engine.GloopExecutionContext context,
XReadArgs.StreamOffset<Object>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
static List<StreamMessage<Object,Object>> |
xreadgroup(String connectionName,
Consumer<Object> consumer,
XReadArgs args,
io.toro.gloop.engine.GloopExecutionContext context,
XReadArgs.StreamOffset<Object>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
static Future<List<StreamMessage<Object,Object>>> |
xreadgroupAsync(String connectionName,
Consumer<Object> consumer,
io.toro.gloop.engine.GloopExecutionContext context,
XReadArgs.StreamOffset<Object>... streams)
Asynchronously read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
static Future<List<StreamMessage<Object,Object>>> |
xreadgroupAsync(String connectionName,
Consumer<Object> consumer,
XReadArgs args,
io.toro.gloop.engine.GloopExecutionContext context,
XReadArgs.StreamOffset<Object>... streams)
Asynchronously read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
static List<StreamMessage<Object,Object>> |
xrevrange(String connectionName,
Object key,
Range<String> range,
io.toro.gloop.engine.GloopExecutionContext context)
Read messages from a stream within a specific
Range in reverse order. |
static List<StreamMessage<Object,Object>> |
xrevrange(String connectionName,
Object key,
Range<String> range,
Limit limit,
io.toro.gloop.engine.GloopExecutionContext context)
|
static Future<List<StreamMessage<Object,Object>>> |
xrevrangeAsync(String connectionName,
Object key,
Range<String> range,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously read messages from a stream within a specific
Range in reverse order. |
static Future<List<StreamMessage<Object,Object>>> |
xrevrangeAsync(String connectionName,
Object key,
Range<String> range,
Limit limit,
io.toro.gloop.engine.GloopExecutionContext context)
|
static Long |
xtrim(String connectionName,
Object key,
boolean approximateTrimming,
long count,
io.toro.gloop.engine.GloopExecutionContext context)
Trims the stream to
count elements. |
static Long |
xtrim(String connectionName,
Object key,
long count,
io.toro.gloop.engine.GloopExecutionContext context)
Trims the stream to
count elements. |
static Future<Long> |
xtrimAsync(String connectionName,
Object key,
boolean approximateTrimming,
long count,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously trims the stream to
count elements. |
static Future<Long> |
xtrimAsync(String connectionName,
Object key,
long count,
io.toro.gloop.engine.GloopExecutionContext context)
Asynchronously trims the stream to
count elements. |
@Autowired RedisStreamMethods(DataSourceManager dataSourceManager)
@GloopParameter(name="redisXackOutput") public static Long xack(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object group, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) String... messageIds)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.group
- name of the consumer group.messageIds
- message Id's to acknowledge.@GloopParameter(name="redisFutureXackOutput") public static Future<Long> xackAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object group, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) String... messageIds)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.group
- name of the consumer group.messageIds
- message id's to acknowledge.@GloopParameter(name="redisXaddOutput") public static String xadd(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopObjectParameter(value="redisMap[]{\n name:object\n value:object\n}\n") io.toro.gloop.object.property.GloopModel redisMap, io.toro.gloop.engine.GloopExecutionContext context)
key
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.redisMap
- message body.@GloopParameter(name="redisXaddOutput") public static String xadd(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) XAddArgs args, @GloopObjectParameter(value="redisMap[]{\n name:object\n value:object\n}\n") io.toro.gloop.object.property.GloopModel redisMap, io.toro.gloop.engine.GloopExecutionContext context)
key
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.redisMap
- message body.@GloopParameter(name="redisXaddOutput") public static String xadd(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keysAndValues)
key
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.keysAndValues
- message body.@GloopParameter(name="redisXaddOutput") public static String xadd(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) XAddArgs args, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keysAndValues)
key
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.keysAndValues
- message body.@GloopParameter(name="redisFutureXaddOutput") public static Future<String> xaddAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopObjectParameter(value="redisMap[]{\n name:object\n value:object\n}\n") io.toro.gloop.object.property.GloopModel redisMap, io.toro.gloop.engine.GloopExecutionContext context)
key
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.redisMap
- message body.@GloopParameter(name="redisFutureXaddOutput") public static Future<String> xaddAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) XAddArgs args, @GloopObjectParameter(value="redisMap[]{\n name:object\n value:object\n}\n") io.toro.gloop.object.property.GloopModel redisMap, io.toro.gloop.engine.GloopExecutionContext context)
key
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.redisMap
- message body.@GloopParameter(name="redisFutureXaddOutput") public static Future<String> xaddAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keysAndValues)
key
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.keysAndValues
- message body.@GloopParameter(name="redisFutureXaddOutput") public static Future<String> xaddAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) XAddArgs args, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keysAndValues)
key
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.keysAndValues
- message body.@GloopParameter(name="redisXclaimOutput") public static List<StreamMessage<Object,Object>> xclaim(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Consumer<Object> consumer, @GloopParameter(allowNull=false) long minIdleTime, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) String... messageIds)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.consumer
- consumer identified by group name and consumer key.messageIds
- message Id's to claim.StreamMessage
@GloopParameter(name="redisXclaimOutput") public static List<StreamMessage<Object,Object>> xclaim(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Consumer<Object> consumer, @GloopParameter(allowNull=false) XClaimArgs args, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) String... messageIds)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.consumer
- consumer identified by group name and consumer key.messageIds
- message Id's to claim.StreamMessage
@GloopParameter(name="redisFutureXclaimOutput") public static Future<List<StreamMessage<Object,Object>>> xclaimAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Consumer<Object> consumer, @GloopParameter(allowNull=false) long minIdleTime, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) String... messageIds)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.consumer
- consumer identified by group name and consumer key.messageIds
- message id's to claim.StreamMessage
@GloopParameter(name="redisFutureXclaimOutput") public static Future<List<StreamMessage<Object,Object>>> xclaimAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Consumer<Object> consumer, @GloopParameter(allowNull=false) XClaimArgs args, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) String... messageIds)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.consumer
- consumer identified by group name and consumer key.messageIds
- message id's to claim.StreamMessage
@GloopParameter(name="redisXdelOutput") public static Long xdel(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) String... messageIds)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.messageIds
- stream message Id's.@GloopParameter(name="redisFutureXdelOutput") public static Future<Long> xdelAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) String... messageIds)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.messageIds
- stream message id's.@GloopParameter(name="redisXgroupCreateOutput") public static String xgroupCreate(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) XReadArgs.StreamOffset<Object> streamOffset, @GloopParameter(allowNull=false) Object group, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namestreamOffset
- name of the stream containing the offset to set.group
- name of the consumer group.@GloopParameter(name="redisFutureXgroupCreateOutput") public static Future<String> xgroupCreateAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) XReadArgs.StreamOffset<Object> streamOffset, @GloopParameter(allowNull=false) Object group, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namestreamOffset
- name of the stream containing the offset to set.group
- name of the consumer group.@GloopParameter(name="redisXgroupDelconsumerOutput") public static Boolean xgroupDelconsumer(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Consumer<Object> consumer, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.consumer
- consumer identified by group name and consumer key.@GloopParameter(name="redisFutureXgroupDelconsumerOutput") public static Future<Boolean> xgroupDelconsumerAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Consumer<Object> consumer, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.consumer
- consumer identified by group name and consumer key.@GloopParameter(name="redisXgroupDestroyOutput") public static Boolean xgroupDestroy(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object group, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.group
- name of the consumer group.@GloopParameter(name="redisFutureXgroupDestroyOutput") public static Future<Boolean> xgroupDestroyAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object group, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.group
- name of the consumer group.@GloopParameter(name="redisXgroupSetidOutput") public static String xgroupSetid(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) XReadArgs.StreamOffset<Object> streamOffset, @GloopParameter(allowNull=false) Object group, io.toro.gloop.engine.GloopExecutionContext context)
group
id.connectionName
- The Martini Runtime Redis connection pool namestreamOffset
- name of the stream containing the offset to set.group
- name of the consumer group.@GloopParameter(name="redisFutureXgroupSetidOutput") public static Future<String> xgroupSetidAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) XReadArgs.StreamOffset<Object> streamOffset, @GloopParameter(allowNull=false) Object group, io.toro.gloop.engine.GloopExecutionContext context)
group
id.connectionName
- The Martini Runtime Redis connection pool namestreamOffset
- name of the stream containing the offset to set.group
- name of the consumer group.@GloopParameter(name="redisXlenOutput") public static Long xlen(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.@GloopParameter(name="redisFutureXlenOutput") public static Future<Long> xlenAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.@GloopParameter(name="redisXpendingOutput") public static List<Object> xpending(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object group, io.toro.gloop.engine.GloopExecutionContext context)
group
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.group
- name of the consumer group.@GloopParameter(name="redisXpendingOutput") public static List<Object> xpending(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object group, @GloopParameter(allowNull=false) Range<String> range, @GloopParameter(allowNull=false) Limit limit, io.toro.gloop.engine.GloopExecutionContext context)
Range
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.group
- name of the consumer group.range
- must not be null.limit
- must not be null.@GloopParameter(name="redisXpendingOutput") public static List<Object> xpending(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Consumer<Object> consumer, @GloopParameter(allowNull=false) Range<String> range, @GloopParameter(allowNull=false) Limit limit, io.toro.gloop.engine.GloopExecutionContext context)
Range
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.consumer
- consumer identified by group name and consumer key.range
- must not be null.limit
- must not be null.@GloopParameter(name="redisFutureXpendingOutput") public static Future<List<Object>> xpendingAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object group, io.toro.gloop.engine.GloopExecutionContext context)
group
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.group
- name of the consumer group.@GloopParameter(name="redisFutureXpendingOutput") public static Future<List<Object>> xpendingAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object group, @GloopParameter(allowNull=false) Range<String> range, @GloopParameter(allowNull=false) Limit limit, io.toro.gloop.engine.GloopExecutionContext context)
Range
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.group
- name of the consumer group.range
- must not be null.limit
- must not be null.@GloopParameter(name="redisFutureXpendingOutput") public static Future<List<Object>> xpendingAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Consumer<Object> consumer, @GloopParameter(allowNull=false) Range<String> range, @GloopParameter(allowNull=false) Limit limit, io.toro.gloop.engine.GloopExecutionContext context)
Range
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.consumer
- consumer identified by group name and consumer key.range
- must not be null.limit
- must not be null.@GloopParameter(name="redisXrangeOutput") public static List<StreamMessage<Object,Object>> xrange(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<String> range, io.toro.gloop.engine.GloopExecutionContext context)
Range
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.range
- must not be null.@GloopParameter(name="redisXrangeOutput") public static List<StreamMessage<Object,Object>> xrange(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<String> range, @GloopParameter(allowNull=false) Limit limit, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.range
- must not be null.limit
- must not be null.@GloopParameter(name="redisFutureXrangeOutput") public static Future<List<StreamMessage<Object,Object>>> xrangeAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<String> range, io.toro.gloop.engine.GloopExecutionContext context)
Range
.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.range
- must not be null.@GloopParameter(name="redisFutureXrangeOutput") public static Future<List<StreamMessage<Object,Object>>> xrangeAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<String> range, @GloopParameter(allowNull=false) Limit limit, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.range
- must not be null.limit
- must not be null.@GloopParameter(name="redisXreadOutput") public static List<StreamMessage<Object,Object>> xread(@GloopParameter(allowNull=false) String connectionName, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) XReadArgs.StreamOffset<Object>... streams)
XReadArgs.StreamOffset
s.connectionName
- The Martini Runtime Redis connection pool namestreams
- the streams to read from.@GloopParameter(name="redisXreadOutput") public static List<StreamMessage<Object,Object>> xread(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) XReadArgs args, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) XReadArgs.StreamOffset<Object>... streams)
XReadArgs.StreamOffset
s.connectionName
- The Martini Runtime Redis connection pool nameargs
- read arguments.streams
- the streams to read from.@GloopParameter(name="redisFutureXreadOutput") public static Future<List<StreamMessage<Object,Object>>> xreadAsync(@GloopParameter(allowNull=false) String connectionName, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) XReadArgs.StreamOffset<Object>... streams)
XReadArgs.StreamOffset
s.connectionName
- The Martini Runtime Redis connection pool namestreams
- the streams to read from.@GloopParameter(name="redisFutureXreadOutput") public static Future<List<StreamMessage<Object,Object>>> xreadAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) XReadArgs args, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) XReadArgs.StreamOffset<Object>... streams)
XReadArgs.StreamOffset
s.connectionName
- The Martini Runtime Redis connection pool nameargs
- read arguments.streams
- the streams to read from.@GloopParameter(name="redisXreadgroupOutput") public static List<StreamMessage<Object,Object>> xreadgroup(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Consumer<Object> consumer, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) XReadArgs.StreamOffset<Object>... streams)
XReadArgs.StreamOffset
s using a consumer group.connectionName
- The Martini Runtime Redis connection pool nameconsumer
- consumer/group.streams
- the streams to read from.@GloopParameter(name="redisXreadgroupOutput") public static List<StreamMessage<Object,Object>> xreadgroup(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Consumer<Object> consumer, @GloopParameter(allowNull=false) XReadArgs args, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) XReadArgs.StreamOffset<Object>... streams)
XReadArgs.StreamOffset
s using a consumer group.connectionName
- The Martini Runtime Redis connection pool nameconsumer
- consumer/group.args
- read arguments.streams
- the streams to read from.@GloopParameter(name="redisFutureXreadgroupOutput") public static Future<List<StreamMessage<Object,Object>>> xreadgroupAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Consumer<Object> consumer, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) XReadArgs.StreamOffset<Object>... streams)
XReadArgs.StreamOffset
s using a consumer group.connectionName
- The Martini Runtime Redis connection pool nameconsumer
- consumer/group.streams
- the streams to read from.@GloopParameter(name="redisFutureXreadgroupOutput") public static Future<List<StreamMessage<Object,Object>>> xreadgroupAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Consumer<Object> consumer, @GloopParameter(allowNull=false) XReadArgs args, io.toro.gloop.engine.GloopExecutionContext context, @GloopParameter(allowNull=false) XReadArgs.StreamOffset<Object>... streams)
XReadArgs.StreamOffset
s using a consumer group.connectionName
- The Martini Runtime Redis connection pool nameconsumer
- consumer/group.args
- read arguments.streams
- the streams to read from.@GloopParameter(name="redisXrevrangeOutput") public static List<StreamMessage<Object,Object>> xrevrange(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<String> range, io.toro.gloop.engine.GloopExecutionContext context)
Range
in reverse order.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.range
- must not be null.@GloopParameter(name="redisXrevrangeOutput") public static List<StreamMessage<Object,Object>> xrevrange(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<String> range, @GloopParameter(allowNull=false) Limit limit, io.toro.gloop.engine.GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.range
- must not be null.limit
- must not be null.@GloopParameter(name="redisFutureXrevrangeOutput") public static Future<List<StreamMessage<Object,Object>>> xrevrangeAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<String> range, io.toro.gloop.engine.GloopExecutionContext context)
Range
in reverse order.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.range
- must not be null.@GloopParameter(name="redisFutureXrevrangeOutput") public static Future<List<StreamMessage<Object,Object>>> xrevrangeAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<String> range, @GloopParameter(allowNull=false) Limit limit, io.toro.gloop.engine.GloopExecutionContext context)
Range
applying a Limit
in reverse
order.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.range
- must not be null.limit
- must not be null.@GloopParameter(name="redisXtrimOutput") public static Long xtrim(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long count, io.toro.gloop.engine.GloopExecutionContext context)
count
elements.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.count
- length of the stream.@GloopParameter(name="redisXtrimOutput") public static Long xtrim(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) boolean approximateTrimming, @GloopParameter(allowNull=false) long count, io.toro.gloop.engine.GloopExecutionContext context)
count
elements.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.approximateTrimming
- @literal true} to trim approximately using the ~
flag.count
- length of the stream.@GloopParameter(name="redisFutureXtrimOutput") public static Future<Long> xtrimAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long count, io.toro.gloop.engine.GloopExecutionContext context)
count
elements.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.count
- length of the stream.@GloopParameter(name="redisFutureXtrimOutput") public static Future<Long> xtrimAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) boolean approximateTrimming, @GloopParameter(allowNull=false) long count, io.toro.gloop.engine.GloopExecutionContext context)
count
elements.connectionName
- The Martini Runtime Redis connection pool namekey
- the stream key.approximateTrimming
- @literal true} to trim approximately using the ~
flag.count
- length of the stream.Copyright © 2020. All rights reserved.