diff --git a/pyinfra/queue/queue_manager.py b/pyinfra/queue/queue_manager.py
index e5db562..c12be9f 100644
--- a/pyinfra/queue/queue_manager.py
+++ b/pyinfra/queue/queue_manager.py
@@ -82,7 +82,8 @@ class QueueManager(object):
                 self._channel.basic_ack(frame.delivery_tag)
             except Exception as ex:
                 n_attempts = _get_n_previous_attempts(properties) + 1
-                logger.warning(f"Message failed to process, {n_attempts} attempts, error {str(ex)}: message: {body}")
+                logger.warning(f"Failed to process message, {n_attempts} attempts, error: {str(ex)}")
+                raise ex
 
         return callback