@@ -861,7 +861,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
- def start_extract_AI_listener(self,_count=4):
+ def start_extract_AI_listener(self,_count=6):
self.list_extract_ai_comsumer = []