summaryrefslogtreecommitdiff
path: root/redis/client.py
diff options
context:
space:
mode:
Diffstat (limited to 'redis/client.py')
-rwxr-xr-xredis/client.py13
1 files changed, 12 insertions, 1 deletions
diff --git a/redis/client.py b/redis/client.py
index 410cdac..45b9879 100755
--- a/redis/client.py
+++ b/redis/client.py
@@ -432,7 +432,10 @@ class StrictRedis(object):
'XINFO CONSUMERS': parse_xinfo_list,
'XINFO GROUPS': parse_xinfo_list
},
- string_keys_to_dict('XACK', int),
+ string_keys_to_dict(
+ 'XACK XDEL',
+ int
+ ),
string_keys_to_dict(
'INCRBYFLOAT HINCRBYFLOAT GEODIST',
float
@@ -1962,6 +1965,14 @@ class StrictRedis(object):
"""
return self.execute_command('XACK', name, groupname, *ids)
+ def xdel(self, name, *ids):
+ """
+ Deletes one or more messages from a stream.
+ name: name of the stream.
+ *ids: message ids to delete.
+ """
+ return self.execute_command('XDEL', name, *ids)
+
# SORTED SET COMMANDS
def zadd(self, name, *args, **kwargs):
"""