

def _extract_params(self, kw):
    host = kw.get('host', 'localhost')
    user = kw.get('user', 'guest')
    password = kw.get('password', 'guest')
    port = kw.get('port', 5672)
    vhost = kw.get('vhost', '/')
    library = kw.get('library', 'librabbitmq')
    exchange_name = kw.get('exchange')
    exchange_type = kw.get('exchange_type', 'topic')
    if (exchange_name is None):
        raise NotabeneException("No 'exchange' name provided")
    connection_dict = {
        'host': host,
        'port': port,
        'user': user,
        'password': password,
        'library': library,
        'vhost': vhost,
    }
    connection_tuple = tuple(sorted(connection_dict.items()))
    exchange_dict = {
        'exchange_name': exchange_name,
        'exchange_type': exchange_type,
    }
    exchange_tuple = tuple(sorted(exchange_dict.items()))
    return (connection_dict, connection_tuple, exchange_dict, exchange_tuple)

dataset/ETHPy150Open openstack/stacktach-winchester/winchester/pipeline_handler.py ConnectionManager._extract_params/original