in inject/inject-logback/src/main/scala/ch/qos/logback/core/LogbackAsyncAppenderBase.scala [129:147]
private[this] def put(eventObject: ILoggingEvent): Unit = {
if (this.neverBlock) {
if (!this.blockingQueue.offer(eventObject)) {
scopedStatsReceiver
.counter(s"events/discarded/${eventObject.getLevel.toString.toLowerCase}")
.incr()
}
} else {
try {
this.blockingQueue.put(eventObject)
} catch {
case NonFatal(t) =>
scopedStatsReceiver
.counter(s"events/discarded/${eventObject.getLevel.toString.toLowerCase}")
.incr()
if (t.isInstanceOf[InterruptedException]) Thread.currentThread.interrupt()
}
}
}