From d0ba649ac09041d6cf78c9a8f9c960bc90ea745e Mon Sep 17 00:00:00 2001
From: descholar-ceo <emmanuellamugi@gmail.com>
Date: Mon, 12 Feb 2024 21:30:32 +0200
Subject: [PATCH] Manually acknowledge messages

---
 src/gato/runner.cr | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/gato/runner.cr b/src/gato/runner.cr
index c21ef62..fc73b88 100644
--- a/src/gato/runner.cr
+++ b/src/gato/runner.cr
@@ -12,7 +12,7 @@ module Gato
             message = JSON.parse msg.body_io.to_s
             Log.notice { "Received a new Message" }
             param[0][:block].call message
-            ch.basic_ack(msg.delivery_tag)
+            msg.ack
             Log.notice { "Done" }
           end
         end