本文整理了Java中ch.qos.logback.core.AsyncAppenderBase.setNeverBlock()
方法的一些代码示例,展示了AsyncAppenderBase.setNeverBlock()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AsyncAppenderBase.setNeverBlock()
方法的具体详情如下:
包路径:ch.qos.logback.core.AsyncAppenderBase
类名称: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();
}
内容来源于网络,如有侵权,请联系作者删除!