Add support for RabbitMQ cluster.

5 years ago · 1debba1829
parent 020bffaa90
commit 1debba1829
1 changed files with 7 additions and 4 deletions
--- a/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/ConnectionPool.cs
+++ b/framework/src/Volo.Abp.RabbitMQ/Volo/Abp/RabbitMQ/ConnectionPool.cs
@ -26,10 +26,13 @@ namespace Volo.Abp.RabbitMQ
            return Connections.GetOrAdd(
                connectionName,
-                () => Options
+                () =>
-                    .Connections
+                {
-                    .GetOrDefault(connectionName)
+                    var connection = Options.Connections.GetOrDefault(connectionName);
-                    .CreateConnection()
+                    var hostnames = connection.HostName.TrimEnd(';').Split(';');
                    // Handle Rabbit MQ Cluster.
                    return hostnames.Length == 1 ? connection.CreateConnection() : connection.CreateConnection(hostnames);
                }
            );
        }