} catch (final InvalidQueryException e) { L89: if (logger.isDebugEnabled()) { L90: logger.debug("Invalid query: {}", body.q, e); L91: } L92: throwValidationErrorApi(e.getMessageCode()); L93: } catch (final ResultOffsetExceededException e) { L94: if (logger.isDebugEnabled()) { L95: logger.debug("Invalid offset: {}", body.offset, e); L96: } L97: throwValidationErrorApi(messages -> messages.ad...

AbstractFessFileTransformer { L30: private static final Logger logger = LogManager.getLogger(FessStandardTransformer.class); L31: L32: @PostConstruct L33: public void init() { L34: if (logger.isDebugEnabled()) { L35: logger.debug("Initialize {}", this.getClass().getSimpleName()); L36: } L37: fessConfig = ComponentUtil.getFessConfig(); L38: } L39: L40: @Override L41: public FessConfig getFessConfig() { L42: return fessConfig; L43: } L44: L45:...

AbstractFessFileTransformer { L30: private static final Logger logger = LogManager.getLogger(FessFileTransformer.class); L31: L32: @PostConstruct L33: public void init() { L34: if (logger.isDebugEnabled()) { L35: logger.debug("Initialize {}", this.getClass().getSimpleName()); L36: } L37: fessConfig = ComponentUtil.getFessConfig(); L38: } L39: L40: @Override L41: public FessConfig getFessConfig() { L42: return fessConfig; L43: } L44: L45:...

logger = LogManager.getLogger(DocumentHelper.class); L68: L69: protected static final String SIMILAR_DOC_HASH_PREFIX = "$"; L70: L71: @PostConstruct L72: public void init() { L73: if (logger.isDebugEnabled()) { L74: logger.debug("Initialize {}", this.getClass().getSimpleName()); L75: } L76: try { L77: final TikaExtractor tikaExtractor = ComponentUtil.getComponent("tikaExtractor"); L78: if (tikaExtractor != null) { L79: ti...

final Logger logger = LogManager.getLogger(IngestFactory.class); L25: L26: private Ingester[] ingesters = {}; L27: L28: public synchronized void add(final Ingester ingester) { L29: if (logger.isDebugEnabled()) { L30: logger.debug("Loaded {}", ingester.getClass().getSimpleName()); L31: } L32: final Ingester[] newIngesters = Arrays.copyOf(ingesters, ingesters.length + 1); L33: newIngesters[ingesters.length] = ingester; L34: Arrays.sort(newIngesters,...

est).map(permissions -> fessConfig.isApiAdminAccessAllowed(permissions)) L31: .orElse(false); L32: } catch (final InvalidAccessTokenException e) { L33: if (logger.isDebugEnabled()) { L34: logger.debug("Invalid access token.", e); L35: } L36: return false; L37: } L38: } L39:}...

L84: L85: protected Logger searchLogLogger = null; L86: L87: protected ObjectMapper objectMapper = new ObjectMapper(); L88: L89: @PostConstruct L90: public void init() { L91: if (logger.isDebugEnabled()) { L92: logger.debug("Initialize {}", this.getClass().getSimpleName()); L93: } L94: userInfoCache = CacheBuilder.newBuilder()// L95: .maximumSize(userInfoCacheSize)// L96: .expireAfterWrite(userCheckInterval, TimeUnit.MILLISECONDS)//...

out); L160: } catch (final ClientAbortException e) { L161: logger.debug("Client aborts this request.", e); L162: } L163: } catch (final Exception e) { L164: if (!(e.getCause() instanceof ClientAbortException)) { L165: throw new WebApiException(HttpServletResponse.SC_INTERNAL_SERVER_ERROR, e); L166: } L167: logger.debug("Client aborts this request.", e); L168: } L169: } L170: L171: protected void...

null; L50: for (int i = 0; i < 30; i++) { L51: try { L52: return super.selectByPK(id); L53: } catch (final Exception e) { L54: if (logger.isDebugEnabled()) { L55: logger.debug("Failed to select a job by {}", id, e); L56: } L57: lastException = e; L58: ThreadUtil.sleep(RandomUtils.nextLong(500, 5000)); L59: } L60: } L61: logger.warn("Failed to select a...

StringUtils.split(s, "=", 2); L42: if (values.length == 2) { L43: mimetypeMap.put(values[0], values[1]); L44: } L45: })); L46: if (logger.isDebugEnabled()) { L47: logger.debug("loaded filetype: {}", mimetypeMap); L48: } L49: } L50: L51: public void add(final String mimetype, final String filetype) { L52: mimetypeMap.put(mimetype, filetype); L53: } L54: L55: public String get(final String mimetype)...