LogEvent result1 = policy.rewrite(event1);
        LogEvent result2 = policy.rewrite(event2);

        assertEquals(Level.WARN, result1.getLevel());
        assertEquals(Level.WARN, result2.getLevel());
    }

    @Test
    public void test_createPolicy_with_spaces_in_logger_names() {
        ErrorToWarnRewritePolicy policy = ErrorToWarnRewritePolicy.createPolicy("  test.logger  ,  another.logger  ,  third.logger  ");

        appender.append(event);

        final List<LogNotificationEvent> events = ComponentUtil.getLogNotificationHelper().drainAll();
        assertEquals(1, events.size());
        assertEquals("ERROR", events.get(0).getLevel());
        assertEquals("org.codelibs.fess.test", events.get(0).getLoggerName());
        assertEquals("test error message", events.get(0).getMessage());
        assertNull(events.get(0).getThrowable());
    }

            return timestamp;
        }

        /**
         * Returns the log level name.
         *
         * @return the log level name
         */
        public String getLevel() {
            return level;
        }

        /**
         * Returns the logger name.
         *
         * @return the logger name
         */
        public String getLoggerName() {

	public final fun getLevel ()Lokhttp3/logging/HttpLoggingInterceptor$Level;
	public fun intercept (Lokhttp3/Interceptor$Chain;)Lokhttp3/Response;
	public final fun level (Lokhttp3/logging/HttpLoggingInterceptor$Level;)V
	public final fun redactHeader (Ljava/lang/String;)V
	public final fun redactQueryParams ([Ljava/lang/String;)V

        final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
        final Map<String, List<LogNotificationEvent>> eventsByLevel =
                events.stream().collect(Collectors.groupingBy(LogNotificationEvent::getLevel));

        for (final Map.Entry<String, List<LogNotificationEvent>> entry : eventsByLevel.entrySet()) {
            final String level = entry.getKey();

     *            Exception
     */
    public void log(final LogMessage logMessage, final Throwable throwable) {
        assertArgumentNotNull("logMessage", logMessage);

        final LogLevel level = logMessage.getLevel();
        if (isEnabledFor(level)) {
            final String message = logMessage.getMessage();
            switch (level) {
            case DEBUG:
                log.debug(message, throwable);

     * deprecated).
     */
    fun setLevel(level: Level) =
      apply {
        this.level = level
      }

    @JvmName("-deprecated_level")
    @Deprecated(
      message = "moved to var",
      replaceWith = ReplaceWith(expression = "level"),
      level = DeprecationLevel.ERROR,
    )
    fun getLevel(): Level = level

    @Throws(IOException::class)

     */
    public void logEvent(EventType type, Severity severity, String message, Map<String, Object> context) {
        // Check minimum log level filter
        if (severity.getLevel() < minLogLevel.getLevel()) {
            return;
        }

        // Rate limiting check
        if (!checkRateLimit(type)) {
            return;
        }

        try {
            // Update statistics

            for (final String excluded : EXCLUDED_LOGGERS) {
                if (loggerName.startsWith(excluded)) {
                    return;
                }
            }
        }

        if (!event.getLevel().isMoreSpecificThan(getEffectiveMinLevel())) {
            return;
        }

        try {
            if (!ComponentUtil.getFessConfig().isLogNotificationEnabled()) {
                return;
            }

  public void test() throws Exception {
    assertTrue(handler.getStoredLogRecords().isEmpty());
    ExampleClassUnderTest.foo();
    LogRecord record = handler.getStoredLogRecords().get(0);
    assertEquals(Level.INFO, record.getLevel());
    assertThat(record.getMessage()).isEqualTo("message");
    assertThat(record.getThrown()).isEqualTo(EXCEPTION);
  }

  public void testConcurrentModification() throws Exception {