entity.isCrawlerJob() ? Constants.ON : null; L347: form.available = entity.isEnabled() ? Constants.ON : null; L348: } L349: L350: private static OptionalEntity<ScheduledJob> getEntity(final CreateForm form, final String username, final long currentTime) { L351: switch (form.crudMode) { L352: case CrudMode.CREATE: L353: return OptionalEntity.of(new ScheduledJob()).map(entity -> { L354: entity.setCreatedBy(username); L355: entity.s...

L77: L78: public static final int DEFAULT_INTERVAL_TIME_FOR_WEB = 10000; L79: L80: public static final int DEFAULT_NUM_OF_THREAD_FOR_FS = 5; L81: L82: public static final int DEFAULT_NUM_OF_THREAD_FOR_WEB = 1; L83: L84: public static final long DEFAULT_CRAWLING_EXECUTION_INTERVAL = 5000L; L85: L86: public static final String CRAWLING_USER_AGENT_PREFIX = "Mozilla/5.0 (compatible; Fess/"; L87: L88: public static final String CRAWLING_USER_AGENT_SUFFIX = "; +http://fess.codelibs.org/bot.html)";...

public String getId() { L385: return asDocMeta().id(); L386: } L387: L388: public void setId(final String id) { L389: asDocMeta().id(id); L390: } L391: L392: public Long getVersionNo() { L393: return asDocMeta().version(); L394: } L395: L396: public void setVersionNo(final Long version) { L397: asDocMeta().version(version); L398: } L399: L400: @Override L401: public Integer getTimeToLive() { L402: String value = getHandlerParameterMap().get("time_to_live");...

public String getType() { L53: return SYNONYM; L54: } L55: L56: @Override L57: public String getPath() { L58: return path; L59: } L60: L61: @Override L62: public synchronized OptionalEntity<SynonymItem> get(final long id) { L63: if (synonymItemList == null) { L64: reload(null); L65: } L66: L67: for (final SynonymItem synonymItem : synonymItemList) { L68: if (id == synonymItem.getId()) { L69: return Optio...

validateApi(body, messages -> {}); L207: L208: if (StringUtil.isBlank(body.q)) { L209: throwValidationErrorApi(messages -> messages.addErrorsInvalidQueryUnknown(GLOBAL)); L210: } L211: try { L212: final long count = searchHelper.deleteByQuery(request, body); L213: return asJson(new ApiDeleteResponse().count(count).status(Status.OK).result()); L214: } catch (final InvalidQueryException e) { L215: if (logger.isDebugEnabled())...

} else if (values.length == 1) { L133: try { L134: if (Constants.MAPPING_TYPE_LONG.equalsIgnoreCase(mapping.getValue2())) { L135: dataMap.put(mapping.getValue1(), Long.parseLong(values[0])); L136: } else if (Constants.MAPPING_TYPE_DOUBLE.equalsIgnoreCase(mapping.getValue2())) { L137: dataMap.put(mapping.getValue1(), Double.parseDouble(values[0])); L138: ...

logger.info("Starting Crawler.."); L472: } L473: L474: final PathMappingHelper pathMappingHelper = ComponentUtil.getPathMappingHelper(); L475: final SystemHelper systemHelper = ComponentUtil.getSystemHelper(); L476: final long totalTime = systemHelper.getCurrentTimeAsLong(); L477: L478: final CrawlingInfoHelper crawlingInfoHelper = ComponentUtil.getCrawlingInfoHelper(); L479: L480: try { L481: writeTimeToSessionInfo(crawlingInfoHelper, Constants...

rEach(filePath -> { L257: final ZipEntry entry = new ZipEntry(id + "/" + filePath.getFileName().toString()); L258: try { L259: zos.putNextEntry(entry); L260: final long len = Files.copy(filePath, zos); L261: if (logger.isDebugEnabled()) { L262: logger.debug("{}: {}", filePath.getFileName(), len); L263: } L264: } catch (final...

HashSet<>(); L151: L152: protected ActionHook actionHook = new ActionHook(); L153: L154: protected final Set<String> inlineMimeTypeSet = new HashSet<>(); L155: L156: protected Cache<String, FacetResponse> facetCache; L157: L158: protected long facetCacheDuration = 60 * 10L; // 10min L159: L160: protected int textFragmentPrefixLength; L161: L162: protected int textFragmentSuffixLength; L163: L164: protected int textFragmentSize; L165: L166: @PostConstruct L167: public void...

// filetype L453: putResultDataBody(dataMap, fessConfig.getIndexFieldFiletype(), fileTypeHelper.get(mimeType)); L454: } L455: // content_length L456: putResultDataBody(dataMap, fessConfig.getIndexFieldContentLength(), Long.toString(responseData.getContentLength())); L457: // last_modified L458: final Date lastModified = responseData.getLastModified(); L459: if (lastModified != null) { L460: putResultDataBody(dataMap, fessConfig.getInd...