From 360ba8a616cb525053f288ec5dc3fc9719734282 Mon Sep 17 00:00:00 2001
From: wu_xinjun <bent20140204@outlook.com>
Date: 星期一, 07 三月 2022 15:27:37 +0800
Subject: [PATCH] temp
---
src/engine/MessageThreads.py | 32 +++++++++++++++++++++++++++++---
1 files changed, 29 insertions(+), 3 deletions(-)
diff --git a/src/engine/MessageThreads.py b/src/engine/MessageThreads.py
index 13356ed..1e0da3f 100644
--- a/src/engine/MessageThreads.py
+++ b/src/engine/MessageThreads.py
@@ -1,6 +1,15 @@
+import os
import threading
import pika
import time
+import os
+
+# add python path of src to sys.path
+src_path = os.path.join(__file__, *(['..'] * 2))
+src_path = os.path.abspath(src_path)
+sys.path.insert(0, src_path)
+
+from protos import aerial_pb2 as pb
@@ -36,9 +45,10 @@
while True:
try:
if not self.queue.empty():
- msg = self.queue.get()
- if isinstance(msg,str):
- print(msg)
+ data= self.queue.get()
+ if isinstance(data, pb.CapturedData):
+ msg = pb.DataMessage()
+ msg.
else:
body = msg.body
routing_key = msg.routing_key
@@ -230,6 +240,22 @@
ch.basic_ack(delivery_tag = method.delivery_tag)
+class image_data_senderThread(senderThread):
+ def __init__(self,
+ MQparameters,
+ input_msg_queue,
+ sender_id,
+ ):
+ super(command_response_senderThread,self).__init__(
+ MQparameters, \
+ input_msg_queue,
+ sender_id,
+ "image_data",
+ "fanout"
+ )
+
+
+
--
Gitblit v1.9.1