From d51689690b31bd6fbce94c38e3048339bd79b6d5 Mon Sep 17 00:00:00 2001 From: ddlucky Date: Fri, 28 Apr 2023 18:01:49 +0800 Subject: [PATCH] 1 --- DSWeb.DJYMQ/DS7Service.cs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/DSWeb.DJYMQ/DS7Service.cs b/DSWeb.DJYMQ/DS7Service.cs index ada84f4e..4e227b75 100644 --- a/DSWeb.DJYMQ/DS7Service.cs +++ b/DSWeb.DJYMQ/DS7Service.cs @@ -161,7 +161,7 @@ namespace DSWeb.Service.Output.DS7 IModel modelDel = mqConn2.CreateModel(); modelDel.ExchangeDeclare(ExchangeName, ExchangeType.Direct); - modelDel.QueueDeclare($"{QueuePrefix_Letter_RH}{CompanyId}", false, false, false, null); + modelDel.QueueDeclare($"{QueuePrefix_Del}{CompanyId}", false, false, false, null); var consumerDel = new EventingBasicConsumer(modelDel); consumerDel.Received += (ch, ea) => @@ -189,7 +189,7 @@ namespace DSWeb.Service.Output.DS7 }; //第二个参数控制【是否消费掉队列里的数据】 - modelDel.BasicConsume($"{QueuePrefix_Letter_RH}{CompanyId}", true, consumerDel); + modelDel.BasicConsume($"{QueuePrefix_Del}{CompanyId}", true, consumerDel); #endregion @@ -228,7 +228,7 @@ namespace DSWeb.Service.Output.DS7 }; //第二个参数控制【是否消费掉队列里的数据】 - model_Letter_RH.BasicConsume($"{QueuePrefix_Letter_RH}{CompanyId}", false, consumer_Letter_RH); + model_Letter_RH.BasicConsume($"{QueuePrefix_Letter_RH}{CompanyId}", true, consumer_Letter_RH); #endregion @@ -268,7 +268,7 @@ namespace DSWeb.Service.Output.DS7 }; //第二个参数控制【是否消费掉队列里的数据】 - model_Letter_PC.BasicConsume($"{QueuePrefix_Letter_PC}{CompanyId}", false, consumer_Letter_PC); + model_Letter_PC.BasicConsume($"{QueuePrefix_Letter_PC}{CompanyId}", true, consumer_Letter_PC); #endregion