|
@@ -1362,6 +1362,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
|
|
|
if dtmp.fix_columns(self.ots_client,["status","save"],True):
|
|
|
if dtmp.getProperties().get("status",0)>=71:
|
|
|
if dtmp.getProperties().get("save",1)==0:
|
|
|
+ log("extract_dump_ai of docid:%d"%(item.get(document_docid)))
|
|
|
ackMsg(conn,message_id,subscription)
|
|
|
return
|
|
|
break
|