소스 검색

附件数据处理1/10的概率不做处理重新排队列以防止单一数据堵塞队列

luojiehua 1 년 전
부모
커밋
74ed85e9c0
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      BaseDataMaintenance/maintenance/dataflow_mq.py

+ 1 - 1
BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -164,7 +164,7 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
             if _idx==0:
                 log("jump by random")
                 if send_msg_toacmq(self.pool_mq,frame.body,self.mq_attachment):
-                    ackMsg(self.conn,message_id)
+                    ackMsg(conn,message_id)
                     return
 
             if len(page_attachments)==0: