Mark subscriber not queue_exclusive to allow for consumer restarts

NeonGeckoCom · Jan 15, 2025 · 758698e · 758698e
1 parent e7d56b1
commit 758698e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/neon_mq_connector/connector.py b/neon_mq_connector/connector.py
@@ -531,7 +531,7 @@ def register_subscriber(self, name: str, vhost: str,
                                       on_error=on_error, exchange=exchange,
                                       exchange_type=ExchangeType.fanout.value,
                                       exchange_reset=exchange_reset,
-                                      auto_ack=auto_ack, queue_exclusive=True,
+                                      auto_ack=auto_ack, queue_exclusive=False,
                                       skip_on_existing=skip_on_existing,
                                       restart_attempts=restart_attempts)