diff --git a/lib/src/routing/connection_registry.rs b/lib/src/routing/connection_registry.rs
index 3fe2ece..f270116 100644
--- a/lib/src/routing/connection_registry.rs
+++ b/lib/src/routing/connection_registry.rs
@@ -94,7 +94,10 @@ impl ConnectionRegistry {
                     if registry.contains_key(server) {
                         continue;
                     }
-                    registry.insert(server.clone(), create_pool(&self.config).await?);
+                    registry.insert(server.clone(), create_pool(&Config {
+                        uri: format!("{}:{}", server.address, server.port),
+                        ..self.config.clone()
+                    }).await?);
                 }
                 registry.retain(|k, _| servers.contains(k));
                 let _ = self