WIP

YarinOmesi · Sep 2, 2023 · b9c6368 · b9c6368
1 parent ad8c9fd
commit b9c6368
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/...ansit.RabbitMqTransport/RabbitMqTransport/Configuration/RabbitMqBusFactoryConfigurator.cs b/...ansit.RabbitMqTransport/RabbitMqTransport/Configuration/RabbitMqBusFactoryConfigurator.cs
@@ -79,7 +79,7 @@ public bool ExclusiveConsumer
 
         public bool Lazy
         {
-            set => _settings.QueueConfigurator.Lazy = value;
+            set => _settings.Lazy = value;
         }
 
         public TimeSpan? QueueExpiration
@@ -89,37 +89,37 @@ public TimeSpan? QueueExpiration
 
         public bool SingleActiveConsumer
         {
-            set => _settings.QueueConfigurator.SingleActiveConsumer = value;
+            set => _settings.SingleActiveConsumer = value;
         }
 
         public void SetQueueArgument(string key, object value)
         {
-            _settings.QueueConfigurator.SetQueueArgument(key, value);
+            _settings.SetQueueArgument(key, value);
         }
 
         public void SetQueueArgument(string key, TimeSpan value)
         {
-            _settings.QueueConfigurator.SetQueueArgument(key, value);
+            _settings.SetQueueArgument(key, value);
         }
 
         public void SetExchangeArgument(string key, object value)
         {
-            _settings.ExchangeConfigurator.SetExchangeArgument(key, value);
+            _settings.SetExchangeArgument(key, value);
         }
 
         public void SetExchangeArgument(string key, TimeSpan value)
         {
-            _settings.ExchangeConfigurator.SetExchangeArgument(key, value);
+            _settings.SetExchangeArgument(key, value);
         }
 
         public void EnablePriority(byte maxPriority)
         {
-            _settings.QueueConfigurator.EnablePriority(maxPriority);
+            _settings.EnablePriority(maxPriority);
         }
 
         public void SetQuorumQueue(int? replicationFactor = default)
         {
-            _settings.QueueConfigurator.SetQuorumQueue(replicationFactor);
+            _settings.SetQuorumQueue(replicationFactor);
         }
 
         public void Host(RabbitMqHostSettings settings)