tropicoo/yt-dlp-bot
1
1
Fork 0
mirror of https://github.com/tropicoo/yt-dlp-bot.git synced 2025-03-02 01:33:41 +08:00
Code Issues Projects Releases Packages Wiki Activity

Update RMQ message ack logic

Browse source
This commit is contained in:
Taras Terletskyi 2023-11-23 22:40:12 +02:00
parent 87dc752e64
commit 9d927c4411
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
app_worker/worker/core/callbacks.py
View file

@ -18,6 +18,8 @@ class RMQCallbacks:
await self._process_incoming_message(message) await self._process_incoming_message(message)
except Exception: except Exception:
self._log.exception('Critical exception in worker RabbitMQ callback') self._log.exception('Critical exception in worker RabbitMQ callback')
if not message.processed:
await message.reject(requeue=False)
async def _process_incoming_message(self, message: IncomingMessage) -> None: async def _process_incoming_message(self, message: IncomingMessage) -> None:
self._log.info('[x] Received message %s', message.body) self._log.info('[x] Received message %s', message.body)