1

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