BrooklynRestAdmin.java 文件源码

@Async
public Future<String> getDashboardUrl(String application) {
    // search in breadth first order for first sensor that matches
    List<EntitySummary> entities = getRestApi().getEntityApi().list(application);
    Deque<EntitySummary> q = new ArrayDeque<>(entities);
    while (!q.isEmpty()) {
        EntitySummary e = q.remove();
        List<SensorSummary> sensors = getRestApi().getSensorApi().list(application, e.getId());
        for (SensorSummary sensor : sensors) {
            if (sensor.getName().equals("management.url")) {
                String url = String.valueOf(getRestApi().getSensorApi().get(application, e.getId(), sensor.getName(), false));
                LOG.info("found dashboard url={} for application={}", url, application);
                return new AsyncResult<>(url);
            }
        }
        q.addAll(getRestApi().getEntityApi().getChildren(application, e.getId()));
    }

    LOG.info("no dashboard url found for application={}", application);
    return new AsyncResult<>(null);
}