You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@logging.apache.org by ma...@apache.org on 2016/09/04 18:38:21 UTC
[05/36] logging-log4j2 git commit: Update AsyncAppender to use more
generic BlockingQueueFactory
Update AsyncAppender to use more generic BlockingQueueFactory
Project: http://git-wip-us.apache.org/repos/asf/logging-log4j2/repo
Commit: http://git-wip-us.apache.org/repos/asf/logging-log4j2/commit/4ebe495e
Tree: http://git-wip-us.apache.org/repos/asf/logging-log4j2/tree/4ebe495e
Diff: http://git-wip-us.apache.org/repos/asf/logging-log4j2/diff/4ebe495e
Branch: refs/heads/master
Commit: 4ebe495e94689c465d154e24a7b6ff1014dfa547
Parents: b8c9501
Author: Matt Sicker <bo...@gmail.com>
Authored: Wed Jun 15 14:19:16 2016 -0500
Committer: Matt Sicker <bo...@gmail.com>
Committed: Wed Jun 15 14:19:16 2016 -0500
----------------------------------------------------------------------
.../org/apache/logging/log4j/core/appender/AsyncAppender.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/4ebe495e/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java
----------------------------------------------------------------------
diff --git a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java
index 7a449d2..70edc19 100644
--- a/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java
+++ b/log4j-core/src/main/java/org/apache/logging/log4j/core/appender/AsyncAppender.java
@@ -19,7 +19,6 @@ package org.apache.logging.log4j.core.appender;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
-import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.atomic.AtomicLong;
@@ -42,6 +41,7 @@ import org.apache.logging.log4j.core.config.plugins.PluginConfiguration;
import org.apache.logging.log4j.core.config.plugins.PluginElement;
import org.apache.logging.log4j.core.config.plugins.PluginFactory;
import org.apache.logging.log4j.core.impl.Log4jLogEvent;
+import org.apache.logging.log4j.core.util.BlockingQueueFactoryUtil;
import org.apache.logging.log4j.core.util.Constants;
/**
@@ -75,7 +75,7 @@ public final class AsyncAppender extends AbstractAppender {
final boolean ignoreExceptions,
final long shutdownTimeout, final Configuration config, final boolean includeLocation) {
super(name, filter, null, ignoreExceptions);
- this.queue = new ArrayBlockingQueue<>(queueSize);
+ this.queue = BlockingQueueFactoryUtil.getLogEventBlockingQueueFactory().create(queueSize);
this.queueSize = queueSize;
this.blocking = blocking;
this.shutdownTimeout = shutdownTimeout;