@@ -854,7 +854,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
- def start_extract_AI_listener(self,_count=1):
+ def start_extract_AI_listener(self,_count=3):
self.list_extract_ai_comsumer = []