We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a65150a commit 97aeb84Copy full SHA for 97aeb84
1 file changed
src/DotNetCore.CAP.RabbitMQ/IConnectionChannelPool.Default.cs
@@ -109,8 +109,12 @@ private static Func<Task<IConnection>> CreateConnection(RabbitMQOptions options)
109
if (options.HostName.Contains(","))
110
{
111
options.ConnectionFactoryOptions?.Invoke(factory);
112
-
113
- return () => factory.CreateConnectionAsync(AmqpTcpEndpoint.ParseMultiple(options.HostName));
+ var endpoints = AmqpTcpEndpoint.ParseMultiple(options.HostName);
+ foreach (var endpoint in endpoints)
114
+ {
115
+ endpoint.Ssl = factory.Ssl;
116
+ }
117
+ return () => factory.CreateConnectionAsync(endpoints);
118
}
119
120
factory.HostName = options.HostName;
@@ -161,4 +165,4 @@ public virtual bool Return(IChannel channel)
161
165
162
166
return false;
163
167
164
-}
168
+}
0 commit comments