public void put()

in src/main/java/com/aliyun/openservices/aliyun/log/producer/internals/RetryQueue.java [26:36]

• 11 lines of code
• 2 McCabe index (conditional complexity)

  public void put(ProducerBatch batch) {
    putsInProgress.incrementAndGet();
    try {
      if (closed) {
        throw new IllegalStateException("cannot put after the retry queue was closed");
      }
      retryBatches.put(batch);
    } finally {
      putsInProgress.decrementAndGet();
    }
  }