def METHOD_NAME(self):
    queue, msg = self.redis_store.blpop("openaire")
    msg = json.loads(msg.decode('utf-8'))
    k = msg.get('id')
    params = self.add_default_params(msg.get('params'))
    params["service"] = "openaire"
    endpoint = msg.get('endpoint')
    return k, params, endpoint