added default publisher confirmation timeout to the corresponding pub…

…lisher strategy
LykkeCity · Nov 6, 2020 · d907c28 · d907c28
1 parent b341b40
commit d907c28
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/Lykke.RabbitMqBroker/Publisher/FanoutPublishStrategyWithConfirmations.cs b/src/Lykke.RabbitMqBroker/Publisher/FanoutPublishStrategyWithConfirmations.cs
@@ -10,6 +10,7 @@ namespace Lykke.RabbitMqBroker.Publisher
     public sealed class FanoutPublishStrategyWithConfirmations : IRabbitMqPublishStrategy
     {
         private readonly bool _durable;
+        private readonly TimeSpan _defaultConfirmationTimeout = TimeSpan.FromSeconds(5);
 
         public FanoutPublishStrategyWithConfirmations(RabbitMqSubscriptionSettings settings)
         {
@@ -32,7 +33,7 @@ public void Publish(RabbitMqSubscriptionSettings settings, IModel channel, RawMe
                 routingKey: string.Empty,
                 basicProperties: null,
                 body: message.Body);
-            channel.WaitForConfirmsOrDie(settings.PublisherConfirmationTimeout);
+            channel.WaitForConfirmsOrDie(settings.PublisherConfirmationTimeout ?? _defaultConfirmationTimeout);
         }
     }
 }