Added SslOption for TcpEndpoint.

Author: Anton Vorontsov

src/RabbitMQ.Client.Core.DependencyInjection/Configuration/RabbitMqSslOption.cs

@@ -0,0 +1,23 @@
+namespace RabbitMQ.Client.Core.DependencyInjection.Configuration
+{
+    /// <summary>
+    /// Ssl option model.
+    /// </summary>
+    public class RabbitMqSslOption
+    {
+        /// <summary>
+        /// Canonical server name.
+        /// </summary>
+        public string ServerName { get; set; }
+        
+        /// <summary>
+        /// Path to the certificate.
+        /// </summary>
+        public string CertificatePath { get; set; }
+
+        /// <summary>
+        /// Flag that defines if certificate should be used.
+        /// </summary>
+        public bool Enabled { get; set; } = true;
+    }
+}

src/RabbitMQ.Client.Core.DependencyInjection/Configuration/RabbitMqTcpEndpoint.cs

@@ -14,5 +14,13 @@ public class RabbitMqTcpEndpoint
         /// Tcp connection port.
         /// </summary>
         public int Port { get; set; } = 5672;
+        
+        /// <summary>
+        /// Ssl option.
+        /// </summary>
+        /// <remarks>
+        /// Should be null if certificate should not be used.
+        /// </remarks>
+        public RabbitMqSslOption SslOption { get; set; }
     }
 }

src/RabbitMQ.Client.Core.DependencyInjection/Services/RabbitMqConnectionFactory.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Collections.Generic;
 using System.Linq;
 using System.Threading;
 using RabbitMQ.Client.Core.DependencyInjection.Configuration;
@@ -41,8 +42,7 @@ public IConnection CreateRabbitMqConnection(RabbitMqClientOptions options)
 
             if (options.TcpEndpoints?.Any() == true)
             {
-                var clientEndpoints = options.TcpEndpoints.Select(x => new AmqpTcpEndpoint(x.HostName, x.Port)).ToList();
-                return TryToCreateConnection(() => factory.CreateConnection(clientEndpoints), options.InitialConnectionRetries, options.InitialConnectionRetryTimeoutMilliseconds);
+                return CreateConnectionWithTcpEndpoints(options, factory);
             }
 
             return string.IsNullOrEmpty(options.ClientProvidedName)
@@ -57,6 +57,25 @@ public IConnection CreateRabbitMqConnection(RabbitMqClientOptions options)
         /// <returns>A consumer instance <see cref="AsyncEventingBasicConsumer"/>.</returns>
         public AsyncEventingBasicConsumer CreateConsumer(IModel channel) => new AsyncEventingBasicConsumer(channel);
 
+        static IConnection CreateConnectionWithTcpEndpoints(RabbitMqClientOptions options, ConnectionFactory factory)
+        {
+            var clientEndpoints = new List<AmqpTcpEndpoint>();
+            foreach (var endpoint in options.TcpEndpoints)
+            {
+                var sslOption = endpoint.SslOption;
+                if (sslOption != null)
+                {
+                    var convertedOption = new SslOption(sslOption.ServerName, sslOption.CertificatePath, sslOption.Enabled);
+                    clientEndpoints.Add(new AmqpTcpEndpoint(endpoint.HostName, endpoint.Port, convertedOption));
+                }
+                else
+                {
+                    clientEndpoints.Add(new AmqpTcpEndpoint(endpoint.HostName, endpoint.Port));
+                }
+            }
+            return TryToCreateConnection(() => factory.CreateConnection(clientEndpoints), options.InitialConnectionRetries, options.InitialConnectionRetryTimeoutMilliseconds);
+        }
+
         static IConnection CreateNamedConnection(RabbitMqClientOptions options, ConnectionFactory factory)
         {
             if (options.HostNames?.Any() == true)