return ComponentUtil.getSystemProperties().getProperty(key, defaultValue); L236: } L237: L238: protected String getResourcePath(final String path) { L239: final File file = ResourceUtil.getResourceAsFileNoException(path); L240: if (file != null) { L241: return file.getAbsolutePath(); L242: } L243: return null; L244: } L245: L246: @Override L247: public Enumeration<String> getInitParameterNames() { L248: ...

logger.debug("Updating job schedule:{}", scheduledJob.getName()); L88: } L89: try { L90: jobHelper.register(scheduledJob); L91: } catch (final Exception e) { L92: logger.warn("Failed to update schdule {}", scheduledJob, e); L93: } L94: }); L95: schedulerTime = now; L96: }, fessConfig.getSchedulerMonitorIntervalAsInteger(), true); L97: } L98: L99: @Override L100: public LaJobRunner...

("TLS"); L70: sslContext.init(null, trustManagerFactory.getTrustManagers(), null); L71: sslSocketFactory = sslContext.getSocketFactory(); L72: } catch (final 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 ->...

cb.query().addOrderBy_Name_Asc(); L123: }, scheduledJob -> { L124: try { L125: ComponentUtil.getJobHelper().register(cron, scheduledJob); L126: } catch (final Exception e) { L127: logger.error("Failed to start Job {}", scheduledJob.getId(), e); L128: } L129: }); L130: } L131:}...

getPyFilePath() { L155: final StringBuilder buf = new StringBuilder(100); L156: buf.append("WEB-INF"); L157: buf.append(File.separator); L158: buf.append("env"); L159: buf.append(File.separator); L160: buf.append(getExecuteType()); L161: buf.append(File.separator); L162: buf.append("resources"); L163: buf.append(File.separator); L164: buf.append(filename.replaceAll("\\.\\.+", "")); L165: return buf.toString(); L166: } L167: L168:...

dataMap; L151: for (final Ingester ingester : ingestFactory.getIngesters()) { L152: try { L153: target = ingester.process(target, paramMap); L154: } catch (final Exception e) { L155: logger.warn("Failed to process Ingest[{}]", ingester.getClass().getSimpleName(), e); L156: } L157: } L158: return target; L159: } L160: L161: @Override L162: public void commit() { L163: synchronized (docList) { L164: ...

protected void flush() { L103: if (bulkRequestBuilder != null) { L104: final BulkResponse response = bulkRequestBuilder.execute().actionGet(requestTimeout); L105: if (response.hasFailures()) { L106: logger.warn("Failed to update scores: {}", response.buildFailureMessage()); L107: } L108: bulkRequestBuilder = null; L109: } L110: } L111: L112: public int getPriority() { L113: return priority; L114: } L115: L116: public...

dir} L86: L87:# Maximum number of VMA (Virtual Memory Areas) a process can own L88:MAX_MAP_COUNT=262144 L89: L90:# Path to the GC log file L91:#FESS_GC_LOG_FILE=/var/log/fess/gc.log L92: L93:# Fess PID file directory L94:PID_DIR=${packaging.fess.pid.dir} L95: L96:# End of variables that can be overwritten in $DEFAULT L97: L98:# overwrite settings from default file L99:if [ -f "$DEFAULT" ]; then L100: . "$DEFAULT" L101:fi L102: L103:# Define other required variables L104:PID_FILE="$PID_DIR/$NAME.pid"...

validateApi(body, messages -> {}); L141: return charMappingService.getCharMappingFile(body.dictId) L142: .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { L143: file.writeOut(out); L144: })).orElseGet(() -> { L145: throwValidationErrorApi(messages -> messages.addErrorsFailedToDownloadProtwordsFile(GLOBAL)); L146: return null; L147: }); L148:...

dictId; L140: validateApi(body, messages -> {}); L141: return stemmerOverrideService.getStemmerOverrideFile(body.dictId) L142: .map(file -> asStream(new File(file.getPath()).getName()).contentTypeOctetStream().stream(out -> { L143: file.writeOut(out); L144: })).orElseGet(() -> { L145: throwValidationErrorApi(messages -> messages.addErrorsFailedToDownloadProtwordsFile(GLOBAL)); L146: return null; L147:...