Java 类ch.qos.logback.core.BasicStatusManager 实例源码

@Before
public void before() {
    ctx.setName("testctx");
    ctx.setStatusManager(new BasicStatusManager());
    unit.setContext(ctx);
    unit.setName("kafkaAppenderBase");
    unit.setEncoder(encoder);
    unit.setTopic("topic");
    unit.addProducerConfig("bootstrap.servers=localhost:1234");
    unit.setKeyingStrategy(keyingStrategy);
    unit.setDeliveryStrategy(deliveryStrategy);
    ctx.start();
}

@Before
public void before() {
    loggerContext.setName("testctx");
    loggerContext.setStatusManager(new BasicStatusManager());
    nifiAppender.setContext(loggerContext);
    nifiAppender.setName("NifiAppender");
    nifiAppender.setUrl("http://localhost:8000/nifi/");
    nifiAppender.setReceiverPortName("FromLogback");
    nifiAppender.setReceiverPortId("3f5c5ece-4e8f-1c7f-ffff-ffff8a1f130b");
    nifiAppender.setPushInterval(10);
    nifiAppender.setSiteToSiteTransportProtocol("HTTP");
    loggerContext.start();
}