protected Client createClient() { L33: final FessConfig fessConfig = ComponentUtil.getFessConfig(); L34: final String[] hosts = L35: split(address, ",").get(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).toArray(n -> new String[n])); L36: final Builder builder = Settings.builder().putList("http.hosts", hosts).put("processors", fessConfig.getCrawlerHttpProcessors()) L37: .put("http.heartbeat_interval", fessConfig.getFesenHeartbeatInterval());...

Exception e) { L73: logger.warn("Failed to load {}", authorities, e); L74: } L75: } L76: L77: final String[] hosts = split(ResourceUtil.getFesenHttpUrl(), ",") L78: .get(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).toArray(n -> new String[n])); L79: nodeManager = new NodeManager(hosts, node -> request(new CurlRequest(Method.GET, node.getUrl("/")))); L80: nodeManager.setHeartbeatInterval(fessConfig.getFesenHeartbeatInterval());...