rabbitmq: Support non-/ vhosts.

Fixes: #30255.
2025-11-13 10:26:28 +00:00 · 2024-05-31 11:47:15 -04:00
parent a4ff6f9ae5
commit 5814583694
4 changed files with 9 additions and 1 deletions
--- a/zerver/lib/queue.py
+++ b/zerver/lib/queue.py
@@ -89,6 +89,7 @@ class QueueClient(Generic[ChannelT], metaclass=ABCMeta):
        return pika.ConnectionParameters(
            settings.RABBITMQ_HOST,
            port=settings.RABBITMQ_PORT,
+            virtual_host=settings.RABBITMQ_VHOST,
            heartbeat=self.rabbitmq_heartbeat,
            tcp_options=tcp_options,
            ssl_options=ssl_options,