AI提取上线

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -1364,6 +1364,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
                     if dtmp.getProperties().get("save",1)==0:
                         ackMsg(conn,message_id,subscription)
                         return
+                    break
             time.sleep(20)