Update agent_server: create producer only for receive queue, fix up it later

pqai_agent_server/agent_server.py

@@ -23,13 +23,14 @@ if __name__ == "__main__":
 
     # 初始化不同队列的后端
     if use_aliyun_mq:
+        # 实际只创建producer，consumer在工作线程中创建
         receive_queue = AliyunRocketMQQueueBackend(
             config['mq']['endpoints'],
             config['mq']['instance_id'],
             config['mq']['receive_topic'],
-            has_consumer=True, has_producer=True,
+            has_consumer=False, has_producer=True,
             group_id=config['mq']['receive_group'],
-            topic_type='FIFO', await_duration=10
+            topic_type='FIFO'
         )
         send_queue = AliyunRocketMQQueueBackend(
             config['mq']['endpoints'],