From e1f883778b1a51241a018a7f0c5918f91026aae7 Mon Sep 17 00:00:00 2001
From: wu_xinjun <bent20140204@outlook.com>
Date: 星期一, 07 三月 2022 17:19:24 +0800
Subject: [PATCH] read change log and readme.md
---
src/engine/MessageThreads.py | 35 ++++++++++++++++++++---------------
1 files changed, 20 insertions(+), 15 deletions(-)
diff --git a/src/engine/MessageThreads.py b/src/engine/MessageThreads.py
index 1e0da3f..903dea8 100644
--- a/src/engine/MessageThreads.py
+++ b/src/engine/MessageThreads.py
@@ -13,13 +13,13 @@
-class Message(object):
- def __init__(self,sender_id,sender_key,body,routing_key):
- self.sender_id = sender_id
- self.sender_key = sender_key
- self.body = body
- self.routing_key = routing_key
-
+# class Message(object):
+# def __init__(self,sender_id,sender_key,body,routing_key):
+# self.sender_id = sender_id
+# self.sender_key = sender_key
+# self.body = body
+# self.routing_key = routing_key
+# 鏍规嵁鏂扮殑鏁版嵁缁撴瀯鏀瑰啓run
class senderThread(threading.Thread):
def __init__(self, MQparameters,input_msg_queue,sender_id,exchangeName,exchangeType):
super(senderThread,self).__init__()
@@ -48,7 +48,6 @@
data= self.queue.get()
if isinstance(data, pb.CapturedData):
msg = pb.DataMessage()
- msg.
else:
body = msg.body
routing_key = msg.routing_key
@@ -64,6 +63,7 @@
print(e)
break
+# 鏍规嵁鏂扮殑鏁版嵁缁撴瀯鏀瑰啓run
class receiverThread(threading.Thread):
def __init__(self, MQparameters,received_msg_queue,output_response_queue,exchangeName,exchangeType,receiver_id):
super(receiverThread,self).__init__()
@@ -103,6 +103,7 @@
raise NotImplementedError(
"Need to implement the callback function")
+# 鏍规嵁rabbitmq閲嶆柊璁剧疆娑堟伅鍙傛暟
class device_state_senderThread(senderThread):
def __init__(self,
MQparameters,
@@ -116,7 +117,7 @@
"device_state",
"fanout"
)
-
+# 鏍规嵁rabbitmq閲嶆柊璁剧疆娑堟伅鍙傛暟
class device_state_receiverThread(receiverThread):
def __init__(self,
MQparameters,
@@ -135,7 +136,7 @@
response_tag = f"{time.asctime()} received: {body}."
print(response_tag)
ch.basic_ack(delivery_tag = method.delivery_tag)
-
+# 鏍规嵁rabbitmq閲嶆柊璁剧疆娑堟伅鍙傛暟
class alarm_state_senderThread(senderThread):
def __init__(self,
MQparameters,
@@ -149,7 +150,7 @@
"alarm_state",
"fanout"
)
-
+ # 鏍规嵁rabbitmq閲嶆柊璁剧疆娑堟伅鍙傛暟
class alarm_state_receiverThread(receiverThread):
def __init__(self,
MQparameters,
@@ -168,7 +169,7 @@
response_tag = f"{time.asctime()} received: {body}."
print(response_tag)
ch.basic_ack(delivery_tag = method.delivery_tag)
-
+# 鏍规嵁rabbitmq閲嶆柊璁剧疆娑堟伅鍙傛暟
class command_request_senderThread(senderThread):
def __init__(self,
MQparameters,
@@ -182,7 +183,7 @@
"command_request",
"topic"
)
-
+# 鏍规嵁rabbitmq閲嶆柊璁剧疆娑堟伅鍙傛暟
class command_request_receiverThread(receiverThread):
def __init__(self,
MQparameters,
@@ -206,7 +207,7 @@
print(response_tag)
self.response_queue.put(Message(self.receiver_id,self.receiver_id,response_tag,''))
ch.basic_ack(delivery_tag = method.delivery_tag)
-
+# 鏍规嵁rabbitmq閲嶆柊璁剧疆娑堟伅鍙傛暟
class command_response_senderThread(senderThread):
def __init__(self,
MQparameters,
@@ -220,7 +221,7 @@
"command_response",
"fanout"
)
-
+# 鏍规嵁rabbitmq閲嶆柊璁剧疆娑堟伅鍙傛暟
class command_response_receiverThread(receiverThread):
def __init__(self,
MQparameters,
@@ -240,6 +241,7 @@
ch.basic_ack(delivery_tag = method.delivery_tag)
+# TODO
class image_data_senderThread(senderThread):
def __init__(self,
MQparameters,
@@ -254,6 +256,9 @@
"fanout"
)
+class image_data_receiverThread(receiverThread):
+ pass
+
--
Gitblit v1.9.1