code: def bind_topic_exchange(self, exchange_name, routing_key, queue_name):
          
          self._channel.queue_declare(
              queue=queue_name,
              auto_delete=True,
              durable=True,
          )
          self._channel.exchange_declare(
              exchange=exchange_name,
              exchange_type='topic',
              auto_delete=True,
          )
          self._channel.queue_bind(
              exchange=exchange_name,
              queue=queue_name,
              routing_key=routing_key
          )
docs: 绑定主题交换机和队列
          :param exchange_name: 需要绑定的交换机名
          :param routing_key:
          :param queue_name: 需要绑定的交换机队列名
          :return: