Java 类org.apache.logging.log4j.status.StatusConsoleListener 实例源码

private static void setupQueue() throws Exception {
    // MockContextFactory becomes the primary JNDI provider
    final StatusConsoleListener l = new StatusConsoleListener(Level.ERROR);
    StatusLogger.getLogger().registerListener(l);
    MockContextFactory.setAsInitial();
    context = new InitialContext();
    context.rebind(FACTORY_NAME, new QueueConnectionFactoryImpl() );
    //context.rebind(QUEUE_NAME, new MockQueue(QUEUE_NAME));
    //System.setProperty(ConfigurationFactory.CONFIGURATION_FILE_PROPERTY, CONFIG);
    //receiver = new JMSQueueReceiver(FACTORY_NAME, QUEUE_NAME, null, null);
}

@BeforeClass
public static void setupClass() throws Exception {
    // MockContextFactory becomes the primary JNDI provider
    final StatusConsoleListener l = new StatusConsoleListener(Level.ERROR);
    StatusLogger.getLogger().registerListener(l);
    MockContextFactory.setAsInitial();
    context = new InitialContext();
    context.rebind(FACTORY_NAME, new QueueConnectionFactoryImpl() );
    context.rebind(QUEUE_NAME, new MockQueue(QUEUE_NAME));
    ((LoggerContext) LogManager.getContext()).reconfigure();
    receiver = new JMSQueueReceiver(FACTORY_NAME, QUEUE_NAME, null, null);
}

@BeforeClass
public static void setupClass() throws Exception {
    // MockContextFactory becomes the primary JNDI provider
    final StatusConsoleListener l = new StatusConsoleListener(Level.ERROR);
    StatusLogger.getLogger().registerListener(l);
    MockContextFactory.setAsInitial();
    context = new InitialContext();
    context.rebind(FACTORY_NAME, new TopicConnectionFactoryImpl() );
    context.rebind(TOPIC_NAME, new MockTopic(TOPIC_NAME) );
    ((LoggerContext) LogManager.getContext()).reconfigure();
    receiver = new JMSTopicReceiver(FACTORY_NAME, TOPIC_NAME, null, null);
}

@BeforeClass
public static void setupClass() throws Exception {
    // MockContextFactory becomes the primary JNDI provider
    final StatusConsoleListener l = new StatusConsoleListener(Level.ERROR);
    StatusLogger.getLogger().registerListener(l);
    MockContextFactory.setAsInitial();
    context = new InitialContext();
    context.rebind(FACTORY_NAME, new QueueConnectionFactoryImpl() );
    context.rebind(QUEUE_NAME, new MockQueue(QUEUE_NAME));
    System.setProperty(ConfigurationFactory.CONFIGURATION_FILE_PROPERTY, CONFIG);
    receiver = new JMSQueueReceiver(FACTORY_NAME, QUEUE_NAME, null, null);
}

private static void setupQueue() throws Exception {
    // MockContextFactory becomes the primary JNDI provider
    final StatusConsoleListener l = new StatusConsoleListener(Level.ERROR);
    StatusLogger.getLogger().registerListener(l);
    MockContextFactory.setAsInitial();
    context = new InitialContext();
    context.rebind(FACTORY_NAME, new TopicConnectionFactoryImpl() );
    //context.rebind(QUEUE_NAME, new MockQueue(QUEUE_NAME));
    //System.setProperty(ConfigurationFactory.CONFIGURATION_FILE_PROPERTY, CONFIG);
    //receiver = new JMSQueueReceiver(FACTORY_NAME, QUEUE_NAME, null, null);
}

private boolean configureExistingStatusConsoleListener() {
    boolean configured = false;
    for (final StatusListener statusListener : this.logger.getListeners()) {
        if (statusListener instanceof StatusConsoleListener) {
            final StatusConsoleListener listener = (StatusConsoleListener) statusListener;
            listener.setLevel(this.status);
            this.logger.updateListenerLevel(this.status);
            if (this.verbosity == Verbosity.QUIET) {
                listener.setFilters(this.verboseClasses);
            }
            configured = true;
        }
    }
    return configured;
}

private void registerNewStatusConsoleListener() {
    final StatusConsoleListener listener = new StatusConsoleListener(this.status, this.destination);
    if (this.verbosity == Verbosity.QUIET) {
        listener.setFilters(this.verboseClasses);
    }
    this.logger.registerListener(listener);
}

@Test
public void testConfig() {
    // don't bother using "error" since that's the default; try another level
    final LoggerContext ctx = this.init.getLoggerContext();
    ctx.reconfigure();
    final Configuration config = ctx.getConfiguration();
    assertThat(config, instanceOf(XmlConfiguration.class));
    for (final StatusListener listener : StatusLogger.getLogger().getListeners()) {
        if (listener instanceof StatusConsoleListener) {
            assertSame(listener.getStatusLevel(), Level.INFO);
            break;
        }
    }
    final Layout<? extends Serializable> layout = PatternLayout.newBuilder()
        .withPattern(PatternLayout.SIMPLE_CONVERSION_PATTERN)
        .withConfiguration(config)
        .build();
    // @formatter:off
    final FileAppender appender = FileAppender.newBuilder()
        .withFileName(LOG_FILE)
        .withAppend(false)
        .withName("File")
        .withIgnoreExceptions(false)
        .withBufferSize(4000)
        .withBufferedIo(false)
        .withLayout(layout)
        .build();
    // @formatter:on
    appender.start();
    config.addAppender(appender);
    final AppenderRef ref = AppenderRef.createAppenderRef("File", null, null);
    final AppenderRef[] refs = new AppenderRef[] {ref};

    final LoggerConfig loggerConfig = LoggerConfig.createLogger(false, Level.INFO, "org.apache.logging.log4j",
        "true", refs, null, config, null );
    loggerConfig.addAppender(appender, null, null);
    config.addLogger("org.apache.logging.log4j", loggerConfig);
    ctx.updateLoggers();
    final Logger logger = ctx.getLogger(CustomConfigurationTest.class.getName());
    logger.info("This is a test");
    final File file = new File(LOG_FILE);
    assertThat(file, exists());
    assertThat(file, hasLength(greaterThan(0L)));
}