summaryrefslogtreecommitdiff
path: root/redis/client.py
diff options
context:
space:
mode:
Diffstat (limited to 'redis/client.py')
-rwxr-xr-xredis/client.py12
1 files changed, 11 insertions, 1 deletions
diff --git a/redis/client.py b/redis/client.py
index f3492da..410cdac 100755
--- a/redis/client.py
+++ b/redis/client.py
@@ -426,12 +426,13 @@ class StrictRedis(object):
'XGROUP DESTROY': int,
'XGROUP SETID': bool_ok,
'XGROUP DELCONSUMER': int
- },
+ },
{
'XINFO STREAM': parse_xinfo_dict,
'XINFO CONSUMERS': parse_xinfo_list,
'XINFO GROUPS': parse_xinfo_list
},
+ string_keys_to_dict('XACK', int),
string_keys_to_dict(
'INCRBYFLOAT HINCRBYFLOAT GEODIST',
float
@@ -1952,6 +1953,15 @@ class StrictRedis(object):
"""
return self.execute_command('XINFO GROUPS', name)
+ def xack(self, name, groupname, *ids):
+ """
+ Acknowledges the successful processing of one or more messages.
+ name: name of the stream.
+ groupname: name of the consumer group.
+ *ids: message ids to acknowlege.
+ """
+ return self.execute_command('XACK', name, groupname, *ids)
+
# SORTED SET COMMANDS
def zadd(self, name, *args, **kwargs):
"""