From 46d1a314413f1271294f925078fa197eaf022463 Mon Sep 17 00:00:00 2001 From: Tuna Celik Date: Tue, 18 Aug 2020 11:26:25 +0200 Subject: [PATCH] Improved rabbitmq connection lost recovery --- radicale/hook/rabbitmq/__init__.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/radicale/hook/rabbitmq/__init__.py b/radicale/hook/rabbitmq/__init__.py index 556c1511..638ca522 100644 --- a/radicale/hook/rabbitmq/__init__.py +++ b/radicale/hook/rabbitmq/__init__.py @@ -1,5 +1,5 @@ import pika -from pika.exceptions import ChannelWrongStateError +from pika.exceptions import ChannelWrongStateError, StreamLostError from radicale import hook from radicale.hook import HookNotificationItem @@ -39,7 +39,8 @@ class Hook(hook.BaseHook): ) ) except Exception as e: - if isinstance(e, ChannelWrongStateError) and recall: + if (isinstance(e, ChannelWrongStateError) or + isinstance(e, StreamLostError)) and recall: self._make_connection_synced() self._notify(notification_item, False) return