{ L82: setupEpg(_epgMap, et -> ((Group) et).getGidNumber(), (et, vl) -> ((Group) et).setGidNumber(DfTypeUtil.toLong(vl)), "gidNumber"); L83: setupEpg(_epgMap, et -> ((Group) et).getName(), (et, vl) -> ((Group) et).setName(DfTypeUtil.toString(vl)), "name"); L84: } L85: L86: @Override L87: public PropertyGateway findPropertyGateway(final String prop) { L88: return doFindEpg(_epgMap, prop); L89: } L90: L91: // ======================================================...

end('_').append(language).append("=ctx._source.").append(f); L134: } L135: } L136: if (logger.isDebugEnabled()) { L137: logger.debug("update script: {}", buf); L138: } L139: return new Script(buf.toString()); L140: } L141: L142: public String getReindexScriptSource() { L143: final FessConfig fessConfig = ComponentUtil.getFessConfig(); L144: final String langField = fessConfig.getIndexFieldLang(); L145: final String code...

sb.append(dm).append(updatedTime); L129: sb.append(dm).append(virtualHost); L130: if (sb.length() > dm.length()) { L131: sb.delete(0, dm.length()); L132: } L133: sb.insert(0, "{").append("}"); L134: return sb.toString(); L135: } L136: L137: // =================================================================================== L138: // Accessor L139: // ...

sb.append(dm).append(updatedBy); L136: sb.append(dm).append(updatedTime); L137: if (sb.length() > dm.length()) { L138: sb.delete(0, dm.length()); L139: } L140: sb.insert(0, "{").append("}"); L141: return sb.toString(); L142: } L143: L144: // =================================================================================== L145: // Accessor L146: // ...

checkGetMethod(Collections.emptyMap(), getAvailableEndpointSuffix() + "/").body().jsonPath().get("response.plugins"); L136: final Map<String, Object> targetMap = L137: available.stream().filter(map -> !map.get("name").toString().startsWith("fess-")).toList().get(0); L138: final Artifact target = getArtifactFromMap(targetMap); L139: L140: // Install L141: { L142: checkPutMethod(targetMap, getInstallEndpointSuffix()).then().body("response.status",...

public Long getVersionNo() { L145: return asDocMeta().version(); L146: } L147: L148: public void setVersionNo(final Long version) { L149: asDocMeta().version(version); L150: } L151: L152: @Override L153: public String toString() { L154: return "WebAuthentication [webConfig=" + webConfig + ", authRealm=" + authRealm + ", createdBy=" + createdBy + ", createdTime=" L155: + createdTime + ", hostname=" + hostname + ", parameters=" + parameters + ", port="...

header; L95: throwValidationError(messages -> messages.addErrorsInvalidHeaderForRequestFile(GLOBAL, msg), () -> asListHtml(this::saveToken)); L96: } else { L97: try (final CurlResponse response = curlRequest.body(buf.toString()).execute()) { L98: final File tempFile = ComponentUtil.getSystemHelper().createTempFile("esreq_", ".json"); L99: try (final InputStream in = response.getContentAsStream()) { L100: CopyUtil.copy(in,...

ComponentUtil.register(new SystemHelper(), "systemHelper"); L36: crawlerStatsHelper = new CrawlerStatsHelper() { L37: @Override L38: protected void log(final StringBuilder buf) { L39: localLogMsg.set(buf.toString()); L40: } L41: }; L42: crawlerStatsHelper.init(); L43: } L44: L45: public void test_beginDone() { L46: String key = "test"; L47: crawlerStatsHelper.begin(key); L48: crawlerStatsHelper.done(key);...

stream.sorted().reduce((l, r) -> l + r).ifPresent(v -> buf.append(v))); L108: buf.append(CACHE_KEY_SPLITTER); L109: stream(excludes).of(stream -> stream.sorted().reduce((l, r) -> l + r).ifPresent(v -> buf.append(v))); L110: return buf.toString(); L111: } L112: L113:}...

sb.append(dm).append(userSessionId); L206: sb.append(dm).append(virtualHost); L207: if (sb.length() > dm.length()) { L208: sb.delete(0, dm.length()); L209: } L210: sb.insert(0, "{").append("}"); L211: return sb.toString(); L212: } L213: L214: // =================================================================================== L215: // Accessor L216: // ...