ch.qos.logback.core.AsyncAppenderBase.setNeverBlock()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(3.1k)|赞(0)|评价(0)|浏览(96)

本文整理了Java中ch.qos.logback.core.AsyncAppenderBase.setNeverBlock()方法的一些代码示例,展示了AsyncAppenderBase.setNeverBlock()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AsyncAppenderBase.setNeverBlock()方法的具体详情如下:
包路径:ch.qos.logback.core.AsyncAppenderBase
类名称:AsyncAppenderBase
方法名:setNeverBlock

AsyncAppenderBase.setNeverBlock介绍

暂无

代码示例

代码示例来源:origin: dropwizard/dropwizard

protected Appender<E> wrapAsync(Appender<E> appender, AsyncAppenderFactory<E> asyncAppenderFactory, Context context) {
  final AsyncAppenderBase<E> asyncAppender = asyncAppenderFactory.build();
  if (asyncAppender instanceof AsyncAppender) {
    ((AsyncAppender) asyncAppender).setIncludeCallerData(includeCallerData);
  }
  asyncAppender.setQueueSize(queueSize);
  asyncAppender.setDiscardingThreshold(discardingThreshold);
  asyncAppender.setContext(context);
  asyncAppender.setName("async-" + appender.getName());
  asyncAppender.addAppender(appender);
  asyncAppender.setNeverBlock(neverBlock);
  asyncAppender.start();
  if (messageRate == null) {
    return asyncAppender;
  } else {
    return new ThrottlingAppenderWrapper<>(asyncAppender, messageRate.getQuantity(), messageRate.getUnit());
  }
}

代码示例来源:origin: palantir/atlasdb

@Override
public Appender<E> build(LoggerContext context, String applicationName, LayoutFactory<E> layoutFactory,
    LevelFilterFactory<E> levelFilterFactory, AsyncAppenderFactory<E> asyncAppenderFactory) {
  Appender<E> appender = super.build(context, applicationName, layoutFactory, levelFilterFactory,
      asyncAppenderFactory);
  Preconditions.checkState(
      appender instanceof AsyncAppenderBase,
      "The Dropwizard logging factory returned an unexpected appender of type " + appender.getClass()
          + ". NonBlockingFileAppenderFactory requires an async appender to set the neverBlock "
          + "property.");
  ((AsyncAppenderBase) appender).setNeverBlock(true);
  return appender;
}

代码示例来源:origin: io.dropwizard/dropwizard-logging

protected Appender<E> wrapAsync(Appender<E> appender, AsyncAppenderFactory<E> asyncAppenderFactory, Context context) {
  final AsyncAppenderBase<E> asyncAppender = asyncAppenderFactory.build();
  if (asyncAppender instanceof AsyncAppender) {
    ((AsyncAppender) asyncAppender).setIncludeCallerData(includeCallerData);
  }
  asyncAppender.setQueueSize(queueSize);
  asyncAppender.setDiscardingThreshold(discardingThreshold);
  asyncAppender.setContext(context);
  asyncAppender.setName("async-" + appender.getName());
  asyncAppender.addAppender(appender);
  asyncAppender.setNeverBlock(neverBlock);
  asyncAppender.start();
  return asyncAppender;
}

代码示例来源:origin: tony19/logback-android

@Test(timeout = 2000)
 public void eventLossIfNeverBlock() {
 int bufferSize = 10;
 int loopLen = bufferSize * 2;
 delayingListAppender.setDelay(5000); // something greater than the test timeout
 asyncAppenderBase.addAppender(delayingListAppender);
 asyncAppenderBase.setQueueSize(bufferSize);
 asyncAppenderBase.setNeverBlock(true);
 asyncAppenderBase.start();
 for (int i = 0; i < loopLen; i++) {
  asyncAppenderBase.doAppend(i);
 }
 asyncAppenderBase.stop();
 // ListAppender size isn't a reliable test here, so just make sure we didn't
 // have any errors, and that we could complete the test in time.
 statusChecker.assertIsErrorFree();
}

相关文章