public Map getBrokersList()

in src/main/java/org/apache/pulsar/manager/service/impl/BrokersServiceImpl.java [50:91]
39 lines of code
5 McCabe index (conditional complexity)

    public Map<String, Object> getBrokersList(Integer pageNum, Integer pageSize, String cluster, String requestHost) {
        Map<String, Object> brokersMap = Maps.newHashMap();
        List<Map<String, Object>> brokersArray = new ArrayList<>();
        if (directRequestBroker) {
            Map<String, FailureDomain> failureDomains;
            try {
                failureDomains = pulsarAdminService.clusters(requestHost).getFailureDomains(cluster);
            } catch (PulsarAdminException e) {
                PulsarAdminOperationException pulsarAdminOperationException
                        = new PulsarAdminOperationException("Failed to get failureDomains list.");
                log.error(pulsarAdminOperationException.getMessage(), e);
                throw pulsarAdminOperationException;
            }

            List<String>  brokersList;
            try {
                brokersList = pulsarAdminService.brokers(requestHost).getActiveBrokers(cluster);
            } catch (PulsarAdminException e) {
                PulsarAdminOperationException pulsarAdminOperationException
                        = new PulsarAdminOperationException("Failed to get brokers list.");
                log.error(pulsarAdminOperationException.getMessage(), e);
                throw pulsarAdminOperationException;
            }

            String environment = environmentCacheService.getEnvironment(requestHost);

            for (String broker: brokersList) {
                environmentCacheService.setServiceUrlEnvironmentMapping("http://" + broker, environment);
                Map<String, Object> brokerEntity = Maps.newHashMap();
                List<String> failureDomain = this.getFailureDomain(broker, failureDomains);
                brokerEntity.put("broker", broker);
                brokerEntity.put("failureDomain", failureDomain);
                brokersArray.add(brokerEntity);
            }
            brokersMap.put("isPage", false);
            brokersMap.put("total", brokersArray.size());
            brokersMap.put("data", brokersArray);
            brokersMap.put("pageNum", 1);
            brokersMap.put("pageSize", brokersArray.size());
        }
        return brokersMap;
    }