carbonblack.py 文件源码

def _create_queues(self, queue_list):
        for topic in queue_list:
            self.queues.append(
                Queue(
                    name=self.queue_name,
                    exchange=self.exchange,
                    routing_key=topic,
                    durable=False,
                    exclusive=True,
                    no_ack=True
                )
            )