Add MessageNacked to recoverable errors

When the broker is answering with a MessageNacked, we can safely retry. Signed-off-by: Arnaud Morin <[email protected]> Change-Id: Ica162f29e855637f5677b08f8452dcce879a5056
celery · Jun 12, 2023 · c6ed09a · c6ed09a
1 parent f778218
commit c6ed09a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/amqp/connection.py b/amqp/connection.py
@@ -14,7 +14,7 @@
 from .abstract_channel import AbstractChannel
 from .channel import Channel
 from .exceptions import (AMQPDeprecationWarning, ChannelError, ConnectionError,
-                         ConnectionForced, RecoverableChannelError,
+                         ConnectionForced, MessageNacked, RecoverableChannelError,
                          RecoverableConnectionError, ResourceError,
                          error_for_code)
 from .method_framing import frame_handler, frame_writer
@@ -179,6 +179,7 @@ class Connection(AbstractChannel):
     channel_errors = (ChannelError,)
     recoverable_connection_errors = (
         RecoverableConnectionError,
+        MessageNacked,
         socket.error,
         IOError,
         OSError,