diff options
Diffstat (limited to 'redis/client.py')
-rwxr-xr-x | redis/client.py | 12 |
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): """ |