捕获因统计队列不存在引发的 AMQPChannelError 错误

FworkSpider/feapder/db/rabbitMq.py

@@ -447,9 +447,12 @@ class RabbitMQ:
         return self._mq.is_open
 
     def get_message_count(self, queue):
-        message = self._channel.queue.declare(queue, passive=True)
-        # message_count 消息统计是消息发布确认之后的数量，未确认消息无法统计
-        return message.get('message_count')
+        try:
+            message = self._channel.queue.declare(queue, passive=True)
+            # message_count 消息统计是消息发布确认之后的数量，未确认消息无法统计
+            return message.get('message_count')
+        except amqpstorm.exception.AMQPChannelError:
+            return 0
 
     def get_mq_obj(self):
         return self._mq