Merge pull request #8057 from nakshathru/main

Added authentication support for AQMP broker url

Author: alwx

changelog/8057.improvement.md

@@ -0,0 +1,2 @@
+Added authentication support for connecting to external RabbitMQ servers.
+Currently user has to hardcode a username and a password in a URL in order to connect to an external RabbitMQ server.

rasa/core/brokers/pika.py

@@ -6,6 +6,7 @@
 from asyncio import AbstractEventLoop
 from collections import deque
 from typing import Deque, Dict, Optional, Text, Union, Any, List, Tuple
+from urllib.parse import urlparse
 
 import aio_pika
 
@@ -168,7 +169,10 @@ async def _connect(self) -> aio_pika.RobustConnection:
         # The `url` parameter will take precedence over parameters like `login` or
         # `password`.
         if self.host.startswith("amqp"):
-            url = self.host
+
+            parsed_host = urlparse(self.host)
+            amqp_user = f"{self.username}:{self.password}"
+            url = f"{parsed_host.scheme}://{amqp_user}@{parsed_host.netloc}:{self.port}"
 
         ssl_options = _create_rabbitmq_ssl_options(self.host)
         logger.info("Connecting to RabbitMQ ...")