Update agent_service: update main for debug

agent_service.py

@@ -239,6 +239,11 @@ if __name__ == "__main__":
     process_thread = threading.Thread(target=service.process_messages)
     process_thread.start()
 
+    console_input = True
+    if not console_input:
+        process_thread.join()
+        sys.exit(0)
+
     message_id = 0
     while True:
         print("Input next message: ")
@@ -247,8 +252,9 @@ if __name__ == "__main__":
             continue
         message_id += 1
         message = Message.build(MessageType.TEXT, MessageChannel.CORP_WECHAT,
-            'user_id_1','staff_id_0', text, int(time.time() * 1000)
+            '7881302581935903','1688854492669990', text, int(time.time() * 1000)
         )
         message.msgId = message_id
         receive_queue.produce(message)
         time.sleep(0.1)
+    process_thread.join()