rabbit.py 文件源码

def create_queue(self):
        test_queue = 'test-rabbit-{}'.format(utils.rand_name())
        q = kombu.Queue(test_queue, channel=self.ch, durable=False,
                        queue_arguments={"x-expires": 15 * 60 * 1000})
        q.declare()
        return test_queue