optimize for routing key

wu_xinjun

2022-06-21 ee0fccfdd6efc0cdc1cc81dbc67a2bfaae8c7ff1

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