diff --git a/server/mq/core/connection_manager.py b/server/mq/core/connection_manager.py index 8404360..87d7cb7 100644 --- a/server/mq/core/connection_manager.py +++ b/server/mq/core/connection_manager.py @@ -63,11 +63,11 @@ def on_connection_open_error(self, connection, err): self._connected = False def _build_amqp_url(self) -> str: - user = os.getenv("SERVER_RABBIT_USER", "guest") - password = os.getenv("SERVER_RABBIT_PASS", "guest") - host = os.getenv("RABBIT_HOST", "rabbitmq-host") - port = os.getenv("RABBIT_PORT", "5672") - vhost = os.getenv("RABBIT_VHOST", "/") + user = os.getenv("SERVER_RABBIT_USER", "guest").strip() + password = os.getenv("SERVER_RABBIT_PASS", "guest").strip() + host = os.getenv("RABBIT_HOST", "rabbitmq-host").strip() + port = os.getenv("RABBIT_PORT", "5672").strip() + vhost = os.getenv("RABBIT_VHOST", "/").strip() vhost = urllib.parse.quote(vhost, safe="") return f"amqp://{user}:{password}@{host}:{port}/{vhost}"