e.getValue(); L89: if (properyPattern.matcher(k).matches() && !v.startsWith(CIPHER_PREFIX)) { L90: return new Pair<>(k, CIPHER_PREFIX + cipher.encrypt(v)); L91: } L92: return new Pair<>(k, v); L93: }).forEach(e -> { L94: if (buf.length() > 0) { L95: buf.append('\n'); L96: } L97: buf.append(e.getFirst()); L98: buf.append('='); L99: buf.append(e.getSecond()); L100: }); L101: ...

(fessConfig.isThumbnailCrawlerEnabled()) { L128: final ThumbnailManager thumbnailManager = ComponentUtil.getThumbnailManager(); L129: final String thumbnailField = fessConfig.getIndexFieldThumbnail(); L130: docList.stream().forEach(doc -> { L131: if (!thumbnailManager.offer(doc)) { L132: if (logger.isDebugEnabled()) { L133: logger.debug("Removing {}={} from doc[{}]", thumbnailField, doc.get(thumbnailField), L134: ...

convertSortQuery(final FessConfig fessConfig, final QueryContext context, final TermQuery termQuery, L127: final float boost, final String field, final String text) { L128: split(text, ",").of(stream -> stream.filter(StringUtil::isNotBlank).forEach(t -> { L129: final String[] values = t.split("\\."); L130: if (values.length > 2) { L131: throw new InvalidQueryException(messages -> messages.addErrorsInvalidQuerySortValue(UserMessages.GLOBAL_PROPERTY_KEY, text),...

null ? String.join(" ", e.getRoles()) : StringUtil.EMPTY); L543: params.put("User Agent", e.getUserAgent()); L544: e.getSearchFieldLogList().stream().forEach(p -> { L545: params.put(p.getFirst(), p.getSecond()); L546: }); L547: e.getRequestHeaderList().stream().forEach(p -> { L548: params.put(p.getFirst(), p.getSecond()); L549: }); L550: return params; L551: }).get(); L552: } L553: L554: private...

public BulkResponse addAll(final String index, final List<Map<String, Object>> docList, L93: final BiConsumer<Map<String, Object>, IndexRequestBuilder> options) { L94: sentIndex.set(index); L95: docList.forEach(x -> options.accept(x, new IndexRequestBuilder(this, IndexAction.INSTANCE))); L96: sentDocList.addAll(docList); L97: return new BulkResponse(new BulkItemResponse[0], documentSizeByQuery); L98: } L99: L100:...

postcard -> { L104: postcard.setFrom(fessConfig.getMailFromAddress(), fessConfig.getMailFromName()); L105: postcard.addReplyTo(fessConfig.getMailReturnPath()); L106: stream(toAddresses).of(stream -> stream.forEach(address -> { L107: postcard.addTo(address); L108: })); L109: BeanUtil.copyMapToBean(dataMap, postcard); L110: }); L111: saveInfo(messages -> messages.addSuccessSendTestmail(GLOBAL));...

catch (final Throwable t) { L185: logger.warn("Failed to set SessionTrackingMode.", t); L186: } L187: L188: split(fessConfig.getQueryFacetQueries(), "\n").of(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).forEach(s -> { L189: final String[] values = StringUtils.split(s, ":", 2); L190: if (values.length != 2) { L191: return; L192: } L193: final FacetQueryView facetQueryView = new FacetQueryView(); L194:...

if (getLogger().isDebugEnabled()) { L107: getLogger().debug("ExtractData: {}", extractData); L108: } L109: // meta L110: extractData.getKeySet().stream().filter(k -> extractData.getValues(k) != null).forEach(key -> { L111: final String[] values = extractData.getValues(key); L112: metaDataMap.put(key, values); L113: L114: // meta -> content L115: if (fessConfig.isCrawlerMetadataContentIncluded(key))...

dataMap = new HashMap<>(); L87: dataMap.put(fessConfig.getIndexFieldUrl(), url); L88: final List<String> roleTypeList = new ArrayList<>(); L89: stream(crawlingConfig.getPermissions()).of(stream -> stream.forEach(p -> roleTypeList.add(p))); L90: if (url.startsWith("smb:") || url.startsWith("smb1:") || url.startsWith("file:") || url.startsWith("ftp:")) { L91: if (url.endsWith("/")) { L92: // directory...

for (int i = 0; i < NUM; i++) { L129: final String name = getNamePrefix() + i; L130: assertTrue(nameList.contains(name), name); L131: } L132: L133: List<String> idList = getIdList(searchBody); L134: idList.forEach(id -> { L135: // Test: get setting api L136: checkGetMethod(searchBody, getItemEndpointSuffix() + "/" + id).then() L137: .body("response." + getItemEndpointSuffix() + "." + getIdKey(), equalTo(id)) L138: ...