Merge pull request #344 from sarmis/feat/clientprovidedname

feat: allow user to define client provided name
dotnetcore · Mar 5, 2022 · 8b728b9 · 8b728b9
2 parents f657a7e + 96058ac
commit 8b728b9
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/bus/EasyCaching.Bus.RabbitMQ/DefaultRabbitMQBus.cs b/bus/EasyCaching.Bus.RabbitMQ/DefaultRabbitMQBus.cs
@@ -64,7 +64,8 @@ IPooledObjectPolicy<IModel> _objectPolicy
                 VirtualHost = _options.VirtualHost,
                 RequestedConnectionTimeout = System.TimeSpan.FromMilliseconds(_options.RequestedConnectionTimeout),
                 SocketReadTimeout = System.TimeSpan.FromMilliseconds(_options.SocketReadTimeout),
-                SocketWriteTimeout = System.TimeSpan.FromMilliseconds(_options.SocketWriteTimeout)
+                SocketWriteTimeout = System.TimeSpan.FromMilliseconds(_options.SocketWriteTimeout),
+                ClientProvidedName = _options.ClientProvidedName
             };
 
             _subConnection = factory.CreateConnection();

diff --git a/src/EasyCaching.Core/Configurations/BaseRabbitMQOptions.cs b/src/EasyCaching.Core/Configurations/BaseRabbitMQOptions.cs
@@ -51,5 +51,10 @@ public class BaseRabbitMQOptions
         /// Gets or sets queue message automatic deletion time (in milliseconds). Default 864000000 ms (10 days).
         /// </summary>
         public int QueueMessageExpires { get; set; } = 864000000;
+
+        /// <summary>
+        /// Gets or sets the client-provided name for the rabbit connection. Default null (handled by rabbit client)
+        /// </summary>
+        public string ClientProvidedName { get; set; }
     }
 }