From 6d4be793db7bfe31ad12b10c9468d4ef1a5e8f52 Mon Sep 17 00:00:00 2001
From: wu_xinjun <bent20140204@outlook.com>
Date: 星期五, 04 三月 2022 17:30:55 +0800
Subject: [PATCH] second commit
---
src/engine/MessageThreads.py | 18 +++++++++++-------
1 files changed, 11 insertions(+), 7 deletions(-)
diff --git a/src/engine/MessageThreads.py b/src/engine/MessageThreads.py
index 0fd459d..13356ed 100644
--- a/src/engine/MessageThreads.py
+++ b/src/engine/MessageThreads.py
@@ -36,18 +36,22 @@
while True:
try:
if not self.queue.empty():
- msg = self.msg_queue.get()
- body = msg.body
- routing_key = msg.routing_key
- channel.basic_publish(exchange=self.exchangeName, routing_key=routing_key, body=body)
+ msg = self.queue.get()
+ if isinstance(msg,str):
+ print(msg)
+ else:
+ body = msg.body
+ routing_key = msg.routing_key
+ channel.basic_publish(exchange=self.exchangeName, routing_key=routing_key, body=body)
+
+ response_tag = f"{time.asctime()},{self.sender_id} send {self.exchangeName} message to {routing_key}"
- response_tag = f"{time.asctime()},{self.sender_id} send {self.exchangeName} message to {routing_key}"
-
- print(response_tag)
+ print(response_tag)
elif self.queue.empty():
time.sleep(1)
except Exception as e:
+ print(e)
break
class receiverThread(threading.Thread):
--
Gitblit v1.9.1