supporting multinode in Connection

Author: DanielePalaia

examples/getting_started/reconnection_example.py

@@ -91,6 +91,12 @@ def on_link_closed(self, event: Event) -> None:
 
 
 def create_connection() -> Connection:
+    # for multinode specify a list of urls and fill the field urls of Connection instead of url
+    # urls = [
+    #    "amqp://ha_tls-rabbit_node0-1:5602/",
+    #    "amqp://ha_tls-rabbit_node0-2:5602/",
+    #    "amqp://ha_tls-rabbit_node0-3:5602/",
+    # ]
     connection = Connection(
         "amqp://guest:guest@localhost:5672/", on_disconnection_handler=on_disconnected
     )

rabbitmq_amqp_python_client/connection.py

@@ -20,11 +20,17 @@
 class Connection:
     def __init__(
         self,
-        addr: str,
+        # single-node mode
+        url: Optional[str] = None,
+        # multi-node mode
+        urls: Optional[list[str]] = None,
         ssl_context: Optional[SslConfigurationContext] = None,
         on_disconnection_handler: Optional[CB] = None,  # type: ignore
     ):
-        self._addr: str = addr
+        if url is None and urls is None:
+            raise ValueError("You need to specify at least an addr or a list of addr")
+        self._addr: Optional[str] = url
+        self._addrs: Optional[list[str]] = urls
         self._conn: BlockingConnection
         self._management: Management
         self._on_disconnection_handler = on_disconnection_handler
@@ -49,7 +55,8 @@ def dial(self) -> None:
                         self._conf_ssl_context.client_cert.password,
                     )
         self._conn = BlockingConnection(
-            self._addr,
+            url=self._addr,
+            urls=self._addrs,
             ssl_domain=self._ssl_domain,
             on_disconnection_handler=self._on_disconnection_handler,
         )