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/Server.py | 22 +++++++++++-----------
1 files changed, 11 insertions(+), 11 deletions(-)
diff --git a/src/Server.py b/src/Server.py
index af20966..9194321 100644
--- a/src/Server.py
+++ b/src/Server.py
@@ -70,12 +70,12 @@
MQparams=self.parameters,
exchange_name='logs_topic',
exchange_type='topic',
- MQqueue_name=f'logs_queue',
- binding_keys=['server.logs.test0'],
+ MQqueue_name=f'{self.server_name}_logs_queue',
+ binding_keys=[f'{self.server_name}.logs.test0'],
message_queue=self.LogsReceiver_queue
)
self.LogsReceiver_Thread.setDaemon(True)
- self.LogsReceiver_Thread.setName("logs_thread")
+ self.LogsReceiver_Thread.setName("Thread-logsReceiver")
self.LogsReceiver_Thread.start()
# launch images receiver thread
@@ -83,12 +83,12 @@
MQparams=self.parameters,
exchange_name='images_topic',
exchange_type='topic',
- MQqueue_name=f'images_queue',
- binding_keys=["server.images.test0"],
+ MQqueue_name=f'{self.server_name}_images_queue',
+ binding_keys=[f"{self.server_name}.images.test0"],
message_queue=self.ImagesReceiver_queue
)
self.ImagesReceiver_Thread.setDaemon(True)
- self.ImagesReceiver_Thread.setName("images_thread")
+ self.ImagesReceiver_Thread.setName("Thread-imagesReceiver")
self.ImagesReceiver_Thread.start()
# launch plys receiver thread
@@ -96,12 +96,12 @@
MQparams=self.parameters,
exchange_name='plys_topic',
exchange_type='topic',
- MQqueue_name=f'plys_queue',
- binding_keys=['server.plys.test0'],
+ MQqueue_name=f'{self.server_name}_plys_queue',
+ binding_keys=[f'{self.server_name}.plys.test0'],
message_queue=self.PlysReceiver_queue
)
self.PlysReceiver_Thread.setDaemon(True)
- self.PlysReceiver_Thread.setName("plys_thread")
+ self.PlysReceiver_Thread.setName("Thread-plysReceiver")
self.PlysReceiver_Thread.start()
# launch decode thread
@@ -114,7 +114,7 @@
)
self.MsgDecoder_Thread.setDaemon(True)
- self.MsgDecoder_Thread.setName("decode_thread")
+ self.MsgDecoder_Thread.setName("Thread-dataDecoder")
self.MsgDecoder_Thread.start()
@@ -128,7 +128,7 @@
message_queue=self.CommandsSender_queue
)
self.CommandsSender_Thread.setDaemon(True)
- self.CommandsSender_Thread.setName("commands_thread")
+ self.CommandsSender_Thread.setName("Thread-commandsSender")
self.CommandsSender_Thread.start()
--
Gitblit v1.9.1