

def create_exchange(name, exchange_type, exclusive=False, auto_delete=False, durable=True):
    return kombu.entity.Exchange(name, type=exchange_type, exclusive=exclusive, auto_delete=auto_delete, durable=durable)

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