private[this] def put()

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()
      }
    }
  }