[async] use offer and not add which fails

yupiik · Nov 15, 2023 · 0ec0e5d · 0ec0e5d
1 parent 7502f30
commit 0ec0e5d
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/yupiik-logging-jul/src/main/java/io/yupiik/logging/jul/handler/AsyncHandler.java b/yupiik-logging-jul/src/main/java/io/yupiik/logging/jul/handler/AsyncHandler.java
@@ -98,7 +98,7 @@ public AsyncHandler() {
 
         queueSize = ofNullable(logManager.apply(className + ".queue.size"))
                 .map(Integer::parseInt)
-                .orElse(512);
+                .orElse(1024);
         this.queue = new ArrayBlockingQueue<>(queueSize);
 
         final var workerCount = ofNullable(logManager.apply(className + ".worker.count"))
@@ -140,7 +140,9 @@ public void publish(final LogRecord record) {
             // infer in context if needed
             record.getSourceClassName();
             record.getSourceMethodName();
-            queue.add(record);
+            if (!queue.offer(record)) {
+                delegate.publish(record);
+            }
         }
     }