optimize for routing key

wu_xinjun

2022-06-21 ee0fccfdd6efc0cdc1cc81dbc67a2bfaae8c7ff1

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