diff options
| -rw-r--r-- | bot/cogs/rmq.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/bot/cogs/rmq.py b/bot/cogs/rmq.py index c7063acd4..2742fb969 100644 --- a/bot/cogs/rmq.py +++ b/bot/cogs/rmq.py @@ -56,6 +56,7 @@ class RMQ: async for message in self.queue: with message.process(): + message.ack() await self.handle_message(message, message.body.decode()) async def send_text(self, queue: str, data: str): @@ -79,6 +80,9 @@ class RMQ: result = await queue_obj.get(timeout=5, fail=False) await asyncio.sleep(0.5) + if result: + result.ack() + return result async def handle_message(self, message, data): |