

def create_connection(hostname, port, userid, password, transport, virtual_host):
    return kombu.connection.BrokerConnection(hostname=hostname, port=port, userid=userid, password=password, transport=transport, virtual_host=virtual_host)

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