diff --git a/radicale/hook/rabbitmq/__init__.py b/radicale/hook/rabbitmq/__init__.py index dbd79bf5..58789e2b 100644 --- a/radicale/hook/rabbitmq/__init__.py +++ b/radicale/hook/rabbitmq/__init__.py @@ -21,7 +21,7 @@ class Hook(hook.BaseHook): self._channel = connection.channel() def _make_declare_queue_synced(self, topic): - self._channel.queue_declare(queue=topic) + self._channel.queue_declare(queue=topic, durable=True) def notify(self, notification_item): if isinstance(notification_item, HookNotificationItem):