second commit

wu_xinjun

2022-03-04 6d4be793db7bfe31ad12b10c9468d4ef1a5e8f52

 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):