消息队列分级并设置动态消费者

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -76,7 +76,7 @@ class DynamicProcess(Process):
 
     def terminate(self) -> None:
         for i in range(len(self.list_comsumer)):
-            _c = self.list_comsumer
+            _c = self.list_comsumer[i]
             _c.conn.disconnect()
         super().terminate()