Merge pull request #121 from yuriyostapenko/fix-tls

Configure SslOptions for endpoints using amqps scheme
rebus-org · Mar 19, 2024 · 37805a3 · 37805a3
2 parents d31f929 + 19559e5
commit 37805a3
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/Rebus.RabbitMq/Internals/ConnectionManager.cs b/Rebus.RabbitMq/Internals/ConnectionManager.cs
@@ -1,4 +1,4 @@
-using System;
+using System;
 using System.Collections.Generic;
 using System.Diagnostics;
 using System.Linq;
@@ -126,7 +126,8 @@ public ConnectionManager(string connectionString, string inputQueueAddress, IReb
             {
                 try
                 {
-                    return new AmqpTcpEndpoint(new Uri(uriString));
+                    var uri = new Uri(uriString);
+                    return new AmqpTcpEndpoint(uri, uri.Scheme == "amqps" ? new SslOption(uri.Host, enabled: true) : null);
                 }
                 catch (Exception exception)
                 {