From ee0fccfdd6efc0cdc1cc81dbc67a2bfaae8c7ff1 Mon Sep 17 00:00:00 2001
From: wu_xinjun <bent20140204@outlook.com>
Date: 星期二, 21 六月 2022 11:54:17 +0800
Subject: [PATCH] optimize for routing key
---
src/engine/AcquisitionMain.py | 18 +++++++++---------
1 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/src/engine/AcquisitionMain.py b/src/engine/AcquisitionMain.py
index a401666..e2a580c 100644
--- a/src/engine/AcquisitionMain.py
+++ b/src/engine/AcquisitionMain.py
@@ -133,12 +133,12 @@
MQparams=self.parameters,
exchange_name='commands_topic',
exchange_type='topic',
- MQqueue_name="commands_queue",
+ MQqueue_name="server0_commands_queue",
binding_keys=[f"{self.device_id}"],
message_queue=self.CommandsReceiver_queue
)
self.CommandsReceiver_Thread.setDaemon(True)
- self.CommandsReceiver_Thread.setName("commands_thread")
+ self.CommandsReceiver_Thread.setName("Thread-commandsReceiver")
self.CommandsReceiver_Thread.start()
self.threads.append(self.CommandsReceiver_Thread)
@@ -153,7 +153,7 @@
message_queue=self.LogsSender_queue
)
self.LogsSender_Thread.setDaemon(True)
- self.LogsSender_Thread.setName("logs_thread")
+ self.LogsSender_Thread.setName("Thread-logsSender")
self.LogsSender_Thread.start()
self.threads.append(self.LogsSender_Thread)
@@ -167,7 +167,7 @@
message_queue=self.ImagesSender_queue
)
self.ImagesSender_Thread.setDaemon(True)
- self.ImagesSender_Thread.setName("image_thread")
+ self.ImagesSender_Thread.setName("Thread-imageSender")
self.ImagesSender_Thread.start()
self.threads.append(self.ImagesSender_Thread)
@@ -180,7 +180,7 @@
message_queue=self.PlysSender_queue
)
self.PlysSender_Thread.setDaemon(True)
- self.PlysSender_Thread.setName("plys_thread")
+ self.PlysSender_Thread.setName("Thread-plysSender")
self.PlysSender_Thread.start()
self.threads.append(self.PlysSender_Thread)
@@ -196,8 +196,8 @@
device_id=self.device_id,
logs_queue=self.LogsSender_queue,
images_queue=self.ImagesSender_queue,
- init_binding_key="client.client.client",
- init_routing_key="server"
+ init_binding_key=self.device_id,
+ init_routing_key="server0"
)
self.dc = dustCleanerController(
@@ -206,7 +206,7 @@
timeout=self.timeout,
logs_queue=self.LogsSender_queue,
device_id=self.device_id,
- routing_key="server"
+ routing_key="server0"
)
self.mc = microwaveController(
@@ -217,7 +217,7 @@
device_id=self.device_id,
logs_queue=self.LogsSender_queue,
plys_queue=self.PlysSender_queue,
- routing_key="server"
+ routing_key="server0"
)
--
Gitblit v1.9.1