修改附件识别时获取附件信息的并发数

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -474,7 +474,7 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
 
     def flow_attachment_producer_comsumer(self):
         log("start flow_attachment comsumer")
-        mt = MultiThreadHandler(self.queue_attachment,self.comsumer_handle,None,10,1)
+        mt = MultiThreadHandler(self.queue_attachment,self.comsumer_handle,None,10,1,restart=True)
         mt.run()
 
     def set_queue(self,_dict):