

def create_queue(name, exchange, routing_key, exclusive=False, auto_delete=False, queue_arguments=None, durable=True):
    return kombu.Queue(name, exchange, durable=durable, auto_delete=auto_delete, exclusive=exclusive, queue_arguments=queue_arguments, routing_key=routing_key)

dataset/ETHPy150Open openstack/stacktach/stacktach/message_service.py create_queue/original