Implements XACK

2 files changed, 21 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):
         """
diff --git a/tests/test_commands.py b/tests/test_commands.py
index 946934d..1f70230 100644
--- a/tests/test_commands.py
+++ b/tests/test_commands.py
@@ -1732,6 +1732,16 @@ class TestStrictCommands(object):
         assert sr.xtrim(stream_name, 234) == 0
         assert sr.xtrim(stream_name, 234, approximate=False) == 66
 
+    @skip_if_server_version_lt('5.0.0')
+    def test_strict_xack(self, sr):
+        stream_name = 'xack_test_stream'
+        sr.delete(stream_name)
+        group_name = 'xack_test_group'
+
+        assert sr.xack(stream_name, group_name, 0) == 0
+        assert sr.xack(stream_name, group_name, '1-1') == 0
+        assert sr.xack(stream_name, group_name, *[x for x in range(5)]) == 0
+
     def test_strict_zadd(self, sr):
         sr.zadd('a', 1.0, 'a1', 2.0, 'a2', a3=3.0)
         assert sr.zrange('a', 0, -1, withscores=True) == \