修复 写入 错误队列后 没有 ack

src/Pole.Core/Consts.cs

@@ -12,4 +12,3 @@ namespace Pole.Core
         public const string ConsumerExceptionDetailsStr = "pole-consumer-exception-details";
     }
 }
-}

src/Pole.EventBus.Rabbitmq/Consumer/ConsumerManager.cs

@@ -40,7 +40,6 @@ namespace Pole.EventBus.RabbitMQ
         private Timer DistributedMonitorTime { get; set; }
         private Timer DistributedHoldTimer { get; set; }
         const int lockHoldingSeconds = 60;
-        int distributedMonitorTimeLock = 0;
         int distributedHoldTimerLock = 0;
         int heathCheckTimerLock = 0;
         private async Task Start()

src/Pole.EventBus.Rabbitmq/Consumer/ConsumerRunner.cs

@@ -138,10 +138,10 @@ namespace Pole.EventBus.RabbitMQ
                         Model.Model.ExchangeDeclare(errorExchangeName, "direct", true);
                         Model.Model.QueueDeclare(errorQueueName, true, false, false, null);
                         Model.Model.QueueBind(errorQueueName, errorExchangeName, string.Empty);
-                    }
-                    if (!Consumer.Config.AutoAck)
-                    {
-                        Model.Model.BasicAck(ea.DeliveryTag, false);
+                        if (!Consumer.Config.AutoAck)
+                        {
+                            Model.Model.BasicAck(ea.DeliveryTag, false);
+                        }
                     }
                 }
             }