Update projects/RabbitMQ.Client/client/impl/ConsumerDispatching/ConsumerDispatcherBase.cs

lukebakken · paulomorgado · web-flow · commit cbcc64339595 · 2024-05-25T07:25:05.000-07:00
Co-authored-by: Paulo Morgado &lt;470455+paulomorgado@users.noreply.github.com&gt;
diff --git a/projects/RabbitMQ.Client/client/impl/ConsumerDispatching/ConsumerDispatcherBase.cs b/projects/RabbitMQ.Client/client/impl/ConsumerDispatching/ConsumerDispatcherBase.cs
@@ -10,7 +10,7 @@ namespace RabbitMQ.Client.ConsumerDispatching
     internal abstract class ConsumerDispatcherBase
     {
         private static readonly FallbackConsumer s_fallbackConsumer = new FallbackConsumer();
-        private readonly IDictionary<string, IBasicConsumer> _consumers = new ConcurrentDictionary<string, IBasicConsumer>();
+        private readonly ConcurrentDictionary<string, IBasicConsumer> _consumers = new ConcurrentDictionary<string, IBasicConsumer>();
 
         public IBasicConsumer? DefaultConsumer { get; set; }
 

Original file line number	Diff line number	Diff line change
`@@ -10,7 +10,7 @@ namespace RabbitMQ.Client.ConsumerDispatching`
`10`	`10`	`internal abstract class ConsumerDispatcherBase`
`11`	`11`	`{`
`12`	`12`	`private static readonly FallbackConsumer s_fallbackConsumer = new FallbackConsumer();`
`13`		`- private readonly IDictionary<string, IBasicConsumer> _consumers = new ConcurrentDictionary<string, IBasicConsumer>();`
	`13`	`+ private readonly ConcurrentDictionary<string, IBasicConsumer> _consumers = new ConcurrentDictionary<string, IBasicConsumer>();`
`14`	`14`
`15`	`15`	`public IBasicConsumer? DefaultConsumer { get; set; }`
`16`	`16`