diff --git a/coolamqp/backends/pyamqp.py b/coolamqp/backends/pyamqp.py index 82dad65c4fded209b4ce43de7037d5695e822263..a6896e681a5897441c513a1c80a6812a6a022ea5 100644 --- a/coolamqp/backends/pyamqp.py +++ b/coolamqp/backends/pyamqp.py @@ -13,7 +13,7 @@ def translate_exceptions(fun): return fun(*args, **kwargs) except amqp.ChannelError as e: raise RemoteAMQPError(e.reply_code, e.reply_text) - except IOError as e: + except (IOError, amqp.ConnectionForced) as e: raise ConnectionFailedError(e.message) return q