eRefresh(index).execute().actionGet(); L253: final long numOfDeleted = searchEngineClient.deleteByQuery(index, queryBuilder); L254: logger.info("Deleted {} old docs.", numOfDeleted); L255: } catch (final Exception e) { L256: logger.error("Could not delete old docs at {}", dataConfig, e); L257: } L258: } L259: L260: public boolean isFinished() { L261: return finished; L262: } L263: L264: public...

org.dbflute.bhv.readable.CBCall; L28:import org.dbflute.bhv.readable.EntityRowHandler; L29:import org.dbflute.cbean.ConditionBean; L30:import org.dbflute.cbean.result.ListResultBean; L31:import org.dbflute.cbean.result.PagingResultBean; L32:import org.dbflute.exception.IllegalBehaviorStateException; L33:import org.dbflute.optional.OptionalEntity; L34:import org.dbflute.util.DfTypeUtil; L35:import org.opensearch.action.bulk.BulkRequestBuilder; L36:import org.opensearch.action.delete.DeleteRequestBuilder; L37:import...

extends DictionaryItem> file = creator.create(path, timestamp); L65: if (file != null) { L66: return file; L67: } L68: } L69: } catch (final Exception e) { L70: logger.warn("Failed to load {}", fileMap, e); L71: } L72: return null; L73: }).filter(file -> file != null).toArray(n -> new DictionaryFile<?>[n]); L74: } catch (final IOException...

SSLContext sslContext = SSLContext.getInstance("TLS"); L70: sslContext.init(null, trustManagerFactory.getTrustManagers(), null); L71: sslSocketFactory = sslContext.getSocketFactory(); L72: } catch (final Exception e) { L73: logger.warn("Failed to load {}", authorities, e); L74: } L75: } L76: L77: final String[] hosts = split(ResourceUtil.getFesenHttpUrl(), ",") L78: .get(stream -> stream.map(String::t...

}); L111: saveInfo(messages -> messages.addSuccessSendTestmail(GLOBAL)); L112: updateProperty(Constants.NOTIFICATION_TO_PROPERTY, form.notificationTo); L113: systemProperties.store(); L114: } catch (final Exception e) { L115: logger.warn("Failed to send a test mail.", e); L116: saveError(messages -> messages.addErrorsFailedToSendTestmail(GLOBAL)); L117: } L118: L119: return redirectByParam(AdminGeneralAction.class, "notificationTo",...

fConfig.setPermissions(ComponentUtil.getFessConfig().getSearchDefaultDisplayEncodedPermissions()); L213: L214: fileConfigService.store(fConfig); L215: } L216: return configName; L217: } catch (final Exception e) { L218: logger.warn("Failed to create crawling config: {}", form.crawlingConfigPath, e); L219: throwValidationError(messages -> messages.addErrorsFailedToCreateCrawlingConfigAtWizard(GLOBAL), L220: () ->...

badWord.setUpdatedBy(Constants.SYSTEM_USER); L136: badWord.setUpdatedTime(now); L137: badWordBhv.update(badWord); L138: } L139: } catch (final Exception e) { L140: logger.warn("Failed to read a sugget elevate word: {}", list, e); L141: } L142: } L143: searchEngineClient.refresh("_all"); // TODO replace _all L144: } catch (final IOException...

try { L163: processHelper.sendCommand(entity.getSessionId(), Constants.CRAWLER_PROCESS_COMMAND_THREAD_DUMP); L164: saveInfo(messages -> messages.addSuccessPrintThreadDump(GLOBAL)); L165: } catch (final Exception e) { L166: logger.warn("Failed to print a thread dump.", e); L167: throwValidationError(messages -> messages.addErrorsFailedToPrintThreadDump(GLOBAL), this::asListHtml); L168: } L169: }).orElse(() ->...

nameSet.add(values[values.length - 1]); L110: } L111: } L112: } L113: } 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:}...

org.codelibs.fess.entity.FessUser; L53:import org.codelibs.fess.es.user.exentity.Group; L54:import org.codelibs.fess.es.user.exentity.Role; L55:import org.codelibs.fess.es.user.exentity.User; L56:import org.codelibs.fess.exception.LdapConfigurationException; L57:import org.codelibs.fess.exception.LdapOperationException; L58:import org.codelibs.fess.helper.SystemHelper; L59:import org.codelibs.fess.mylasta.direction.FessConfig; L60:import org.codelibs.fess.util.ComponentUtil; L61:import org.codelibs.fess.util.OptionalUtil;...