buf.append(seed).append(CACHE_KEY_SPLITTER); L103: stream(tags).of(stream -> stream.sorted().reduce((l, r) -> l + r).ifPresent(v -> buf.append(v))); L104: buf.append(CACHE_KEY_SPLITTER); L105: stream(roles).of(stream -> stream.sorted().reduce((l, r) -> l + r).ifPresent(v -> buf.append(v))); L106: buf.append(CACHE_KEY_SPLITTER); L107: stream(fields).of(stream -> stream.sorted().reduce((l, r) -> l + r).ifPresent(v -> buf.append(v))); L108: buf.append(CACHE_KEY_SPLITTER);...

(StringUtil.isNotBlank(logFilePath)) { L92: final Path logDirPath = Paths.get(logFilePath); L93: try (Stream<Path> stream = Files.list(logDirPath)) { L94: stream.filter(entry -> isLogFilename(entry.getFileName().toString())).sorted().forEach(filePath -> { L95: final Map<String, Object> map = new HashMap<>(); L96: final String name = filePath.getFileName().toString(); L97: map.put("id", Base64.getUrlEncoder().encodeToS...

(logger.isDebugEnabled()) { L110: logger.debug("{} does not exists.", dir); L111: } L112: return; L113: } L114: try (Stream<Path> walk = Files.walk(dir, FileVisitOption.FOLLOW_LINKS)) { L115: walk.sorted(Comparator.reverseOrder()).forEach(f -> { L116: if (logger.isDebugEnabled()) { L117: logger.debug("Deleting {}", f); L118: } L119: try { L120: Files.delete(f); L121:...

} L114: } L115: } catch (final Exception e) { L116: logger.warn("Failed to load {}", jarFile.getAbsolutePath(), e); L117: } L118: } L119: return nameSet.stream().sorted().collect(Collectors.toList()); L120: } L121: L122:}...

'_').toUpperCase(Locale.ENGLISH)); L125: valueMap.put("user", user.map(FessUserBean::getUserId).orElse("-")); L126: final Comparator<Map.Entry<String, String>> c = Comparator.comparing(Map.Entry::getKey); L127: params.entrySet().stream().sorted(c).forEach(e -> { L128: valueMap.put(e.getKey(), e.getValue().replace('\t', '_')); L129: }); L130: log(valueMap); L131: } L132: L133: protected void log(final Map<String, String> valueMap) { L134: valueMap.put("ip",...