add PublishingChannelsPoolSize option (#521)

Co-authored-by: Thomas Sarmis <t.sarmis@kaizengaming.com>
dotnetcore · Mar 3, 2024 · 1ebd8e8 · 1ebd8e8
1 parent 9c79490
commit 1ebd8e8
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/bus/EasyCaching.Bus.RabbitMQStream/DefaultRabbitMQStreamBus.cs b/bus/EasyCaching.Bus.RabbitMQStream/DefaultRabbitMQStreamBus.cs
@@ -97,6 +97,11 @@ IPooledObjectPolicy<IModel> objectPolicy
                 };
 
                 var provider = new DefaultObjectPoolProvider();
+
+                if (_options.PublishingChannelsPoolSize.HasValue) 
+                {
+                    provider.MaximumRetained = _options.PublishingChannelsPoolSize.Value;
+                }
 
                 _pubChannelPool = provider.Create(objectPolicy);
 

diff --git a/src/EasyCaching.Core/Configurations/BaseRabbitMQOptions.cs b/src/EasyCaching.Core/Configurations/BaseRabbitMQOptions.cs
@@ -56,5 +56,10 @@ public class BaseRabbitMQOptions
         /// Gets or sets the client-provided name for the rabbit connection. Default null (handled by rabbit client)
         /// </summary>
         public string ClientProvidedName { get; set; }
+
+        /// <summary>
+        /// Sets the Pool size for the publishing channels, if null the default is used (default = cpu core count x 2)
+        /// </summary>
+        public int? PublishingChannelsPoolSize { get; set; } = null;
     }
 }