AI提取上线

BaseDataMaintenance/maintenance/dataflow_mq.py

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