From f0476b4f08f5ff2fc3e9cab03924c4e948a510f1 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Sat, 28 May 2016 20:24:53 +0200
Subject: [PATCH] added extra exception to filtering
thing came up while testing
---
coolamqp/backends/pyamqp.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/coolamqp/backends/pyamqp.py b/coolamqp/backends/pyamqp.py
index 82dad65..a6896e6 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
--
GitLab