From 9ff7421d5ffa507e017cebdce78c26bb04967c42 Mon Sep 17 00:00:00 2001
From: Mikhail Trubnikov <ivc_trubnikovme@dvgd.rzd>
Date: Thu, 21 Sep 2023 15:37:38 +1000
Subject: [PATCH] fix mq

---
 PARR.BLL/Services/Implementations/MqService.cs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/PARR.BLL/Services/Implementations/MqService.cs b/PARR.BLL/Services/Implementations/MqService.cs
index ff0882f3..081f142e 100644
--- a/PARR.BLL/Services/Implementations/MqService.cs
+++ b/PARR.BLL/Services/Implementations/MqService.cs
@@ -67,7 +67,7 @@ namespace PARR.BLL.Services.Implementations
                         channel.BasicPublish(exchange: "", routingKey: mqSettings.QueueName, basicProperties: props, body: body);
 
                         sendIdx++;
-                        logger.LogDebug($"Отправлено сообщение в очередь: {mqSettings.QueueName}, {msg}");
+                        logger.LogDebug($"Отправлено сообщение в очередь: {mqSettings.HostName} {mqSettings.QueueName}, {msg}");
                     }
                 }
 
@@ -81,7 +81,7 @@ namespace PARR.BLL.Services.Implementations
                 for (int i = sendIdx; i < msgList.Length; i++)
                     notSendMsg.Add(msgList[i]);
 
-                logger.LogError(ex, $"Ошибка при отправке сообщения в очередь {mqSettings.QueueName}, {string.Join(',', notSendMsg)}");
+                logger.LogError(ex, $"Ошибка при отправке сообщения в очередь {mqSettings.HostName} {mqSettings.QueueName}, {string.Join(',', notSendMsg)}");
 
                 return new MqSendResult { IsSuccess = false, NotSendMessages = notSendMsg.ToArray() };
             }
@@ -104,8 +104,8 @@ namespace PARR.BLL.Services.Implementations
 
             try
             {
-                var connection = facory.CreateConnection();
-                var channel = connection.CreateModel();
+                using var connection = facory.CreateConnection();
+                using var channel = connection.CreateModel();
 
                 var args = new Dictionary<string, object> { { "x-queue-mode", "lazy" } };