diff options
| author |  Gareth Coles <[email protected]> | 2018-07-02 22:43:21 +0100 |
|---|---|---|
| committer | Gareth Coles <[email protected]> | 2018-07-02 22:43:21 +0100 |
| commit | e9b81b000547f4bf2cdf9fea182de335f4a10491 (patch) | |
| tree | 87a07cf4ec917d12f0d9f540b89a24977f1bf815 | |
| parent | [Snekbox] More robust codeblock escape handling (diff) | |
[RMQ] Ack messages
| -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): |