From c83bbe173ed1f2a292afa1ab0c622cefd12c195d Mon Sep 17 00:00:00 2001
From: Cyber MacGeddon <cybermaggedon@gmail.com>
Date: Tue, 26 Nov 2024 13:17:16 +0000
Subject: [PATCH] Acknowledge messaages from Pulsar, doh!

---
 trustgraph-flow/trustgraph/api/gateway/service.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/trustgraph-flow/trustgraph/api/gateway/service.py b/trustgraph-flow/trustgraph/api/gateway/service.py
index 6d5f70ce..a9ed7079 100755
--- a/trustgraph-flow/trustgraph/api/gateway/service.py
+++ b/trustgraph-flow/trustgraph/api/gateway/service.py
@@ -156,6 +156,9 @@ class Subscriber:
                         while True:
                             msg = await consumer.receive()
 
+                            # Acknowledge successful reception of the message
+                            await consumer.acknowledge(msg)
+
                             try:
                                 id = msg.properties()["id"]
                             except: