- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 10 for addTimeoutTarget (0.19 seconds)
-
src/main/java/org/codelibs/fess/exec/SuggestCreator.java
} }; Runtime.getRuntime().addShutdownHook(shutdownCallback); systemMonitorTask = TimeoutManager.getInstance() .addTimeoutTarget(new SystemMonitorTarget(), ComponentUtil.getFessConfig().getSuggestSystemMonitorIntervalAsInteger(), true); if (ComponentUtil.getFessConfig().isLogNotificationEnabled()) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 12.1K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java
} }; Runtime.getRuntime().addShutdownHook(shutdownCallback); systemMonitorTask = TimeoutManager.getInstance() .addTimeoutTarget(new SystemMonitorTarget(), ComponentUtil.getFessConfig().getThumbnailSystemMonitorIntervalAsInteger(), true); if (ComponentUtil.getFessConfig().isLogNotificationEnabled()) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 10.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/LogNotificationHelper.java
logNotificationTarget = new LogNotificationTarget(); final int interval = ComponentUtil.getFessConfig().getLogNotificationFlushIntervalAsInteger(); timeoutTask = TimeoutManager.getInstance().addTimeoutTarget(logNotificationTarget, interval, true); } /** * Stops the log notification timer and performs a final flush. */ @PreDestroy public void destroy() {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 5.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/exec/Crawler.java
.addTimeoutTarget(logNotificationTarget, ComponentUtil.getFessConfig().getLogNotificationFlushIntervalAsInteger(), true); } if (options.hotThread != null) { hotThreadMonitorTask = TimeoutManager.getInstance().addTimeoutTarget(new HotThreadMonitorTarget(), options.hotThread, true); }
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 26 02:24:08 GMT 2026 - 32.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/chat/ChatSessionManager.java
* Initializes the session manager and starts the cleanup scheduler. */ @PostConstruct public void init() { // 5 minutes = 300 seconds cleanupTask = TimeoutManager.getInstance().addTimeoutTarget(this::cleanupExpiredSessions, 300, true); if (logger.isDebugEnabled()) { logger.debug("Initialized ChatSessionManager"); } } /**Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 07 13:27:59 GMT 2026 - 13.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/CoordinatorHelper.java
sendHeartbeat(); final FessConfig fessConfig = ComponentUtil.getFessConfig(); final int interval = fessConfig.getCoordinatorPollIntervalAsInteger(); pollTask = TimeoutManager.getInstance().addTimeoutTarget(this::poll, interval, true); if (logger.isInfoEnabled()) { logger.info("CoordinatorHelper started: instanceId={}", instanceId); } } /**
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 33.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
final int interval = fessConfig.getLoadControlMonitorIntervalAsInteger(); loadControlMonitorTask = TimeoutManager.getInstance().addTimeoutTarget(new LoadControlMonitorTarget(this), interval, true); } } } } } /** * Gets a map of filtered environment variables.
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 43.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/llm/AbstractLlmClient.java
} return; } updateAvailability(); availabilityCheckTask = TimeoutManager.getInstance().addTimeoutTarget(this::updateAvailability, checkInterval, true); if (logger.isDebugEnabled()) { logger.debug("Started {} availability check with interval: {}s", getName(), checkInterval); } }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 21 06:04:58 GMT 2026 - 72K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/sso/entraid/EntraIdAuthenticator.java
logger.debug("[scheduleParentGroupLookup] Scheduling async parent group lookup for user: {}, groupIds count: {}", user.getName(), groupIds.size()); } TimeoutManager.getInstance().addTimeoutTarget(() -> { if (logger.isDebugEnabled()) { logger.debug("[scheduleParentGroupLookup] Async task started for user: {}", user.getName()); }
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sun Mar 15 08:03:27 GMT 2026 - 56.8K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/ldap/LdapManager.java
logger.debug("Roles: {}", roleSet); } final String[] roles = roleSet.toArray(new String[roleSet.size()]); if (!subRoleSet.isEmpty()) { TimeoutManager.getInstance().addTimeoutTarget(() -> { sAMAccountGroupNameSet.stream().forEach(groupName -> { getSAMAccountGroupName(bindDn, groupName).ifPresent(sAMAccountGroupName -> {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Jan 02 08:06:20 GMT 2026 - 85.2K bytes - Click Count (0)