ManagementFactory.getRuntimeMXBean().getInputArguments().stream().forEach(s -> logger.debug("Parameter: {}", s)); L99: System.getProperties().entrySet().stream().forEach(e -> logger.debug("Property: {}={}", e.getKey(), e.getValue())); L100: System.getenv().entrySet().forEach(e -> logger.debug("Env: {}={}", e.getKey(), e.getValue())); L101: logger.debug("Option: {}", options); L102: } catch (final Exception e) { L103: //...

StreamUtil.split(value, ",") L100: .get(stream -> stream.map(String::trim).filter(StringUtil::isNotBlank).collect(Collectors.toUnmodifiableSet())); L101: } L102: if (logger.isDebugEnabled()) { L103: logger.debug("availableSearcherNameSet={}", availableSearcherNameSet); L104: } L105: } L106: L107: @Override L108: @PreDestroy L109: public void close() throws Exception { L110: if (executorService != null) { L111: try { L112:...

(logger.isDebugEnabled()) { L149: logger.debug("Accessing document: {}, status: {}", url, httpStatusCode); L150: } L151: if (httpStatusCode == 404) { L152: storeChildUrlsToQueue(urlQueue, getAnchorSet(document.get(fessConfig.getIndexFieldAnchor()))); L153: if (!indexingHelper.deleteDocument(searchEngineClient, id)) { L154: logger.debug("Failed to delete 404 document: {}", url); L155: ...

if (logger.isDebugEnabled()) { L329: logger.debug("Indexing {}", accessResult.getUrl()); L330: } L331: accessResult.setStatus(Constants.DONE_STATUS); L332: accessResultList.add(accessResult); L333: L334: if (accessResult.getHttpStatusCode() != 200) { L335: // invalid page L336: if (logger.isDebugEnabled()) { L337: logger.debug("Skipped. The response code is {}.", accessResult.getHttpStatusCode());...

try { L317: if (logger.isDebugEnabled()) { L318: logger.debug("Shutting down thread executor."); L319: } L320: executor.shutdown(); L321: executor.awaitTermination(executorTerminationTimeout, TimeUnit.SECONDS); L322: } catch (final InterruptedException e) { L323: if (logger.isDebugEnabled()) { L324: logger.debug("Failed to interrupt executor.", e); L325: } L326: } finally { L327: ...

L101: /** L102: * Get the value for the key 'framework.debug'. <br> L103: * The value is, e.g. false <br> L104: * comment: Does it enable the Framework internal debug? (true only when emergency) L105: * @return The value of found property. (NotNull: if not found, exception but basically no way) L106: */ L107: String getFrameworkDebug(); L108: L109: /** L110: * Is the property for the key 'framework.debug' true? <br> L111: * The value is, e.g. false <br> L112: ...

cipher.decryptoText(rolesStr); L239: } catch (final Exception e) { L240: if (logger.isDebugEnabled()) { L241: logger.debug("Failed to decrypt {}", rolesStr, e); L242: } L243: return; L244: } L245: } L246: L247: if (logger.isDebugEnabled()) { L248: logger.debug("role: original: {}, decrypto: {}", value, rolesStr); L249: } L250: L251: if (valueSeparator.length() > 0) { L252: final...

if (Files.isRegularFile(path)) { L89: return Files.getLastModifiedTime(path).toMillis(); L90: } L91: } catch (final Exception e) { L92: logger.debug("Failed to access {}", key, e); L93: } L94: return 0L; L95: } L96: }); L97: L98: protected FessFunctions() { L99: // nothing L100: } L101: L102: public static Boolean labelExists(final...

new HashMap<>(); L129: L130: protected Set<String> waitingThreadNames = Collections.synchronizedSet(new HashSet<>()); L131: L132: @PostConstruct L133: public void init() { L134: if (logger.isDebugEnabled()) { L135: logger.debug("Initialize {}", this.getClass().getSimpleName()); L136: } L137: final Calendar cal = Calendar.getInstance(TimeZone.getTimeZone("UTC")); L138: cal.set(2026, 3 - 1, 1); // EOL Date L139: eolTime = cal.getTimeInMillis(); L140:...

L846: } L847: L848: if (logger.isDebugEnabled()) { L849: logger.debug("{} -> {}", attrValue, u); L850: } L851: if (StringUtil.isNotBlank(u)) { L852: if (logger.isDebugEnabled()) { L853: logger.debug("Add Child: {}", u); L854: } L855: urlList.add(u); L856: } else if (logger.isDebugEnabled()) { L857: logger.debug("Skip Child: {}", u); L858: } L859: } L860: L861: private boolean isUtf8BomBytes(final...