diff --git a/app_worker/worker/core/callbacks.py b/app_worker/worker/core/callbacks.py
index 9ba9f30..c6aeef4 100644
--- a/app_worker/worker/core/callbacks.py
+++ b/app_worker/worker/core/callbacks.py
@@ -18,6 +18,8 @@ class RMQCallbacks:
             await self._process_incoming_message(message)
         except Exception:
             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:
         self._log.info('[x] Received message %s', message.body)