You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@logging.apache.org by rg...@apache.org on 2016/03/16 01:21:05 UTC

[21/38] logging-log4j2 git commit: LOG4J2-1080 updated AsyncAppender after removing support for dropping events on partially full queue

LOG4J2-1080 updated AsyncAppender after removing support for dropping events on partially full queue


Project: http://git-wip-us.apache.org/repos/asf/logging-log4j2/repo
Commit: http://git-wip-us.apache.org/repos/asf/logging-log4j2/commit/76067f2d
Tree: http://git-wip-us.apache.org/repos/asf/logging-log4j2/tree/76067f2d
Diff: http://git-wip-us.apache.org/repos/asf/logging-log4j2/diff/76067f2d

Branch: refs/heads/LOG4J2-1116
Commit: 76067f2d9e8b32fe305a650aa821b77797791a03
Parents: e91ea51
Author: rpopma <rp...@apache.org>
Authored: Tue Mar 15 01:59:10 2016 +1100
Committer: rpopma <rp...@apache.org>
Committed: Tue Mar 15 01:59:10 2016 +1100

----------------------------------------------------------------------
 .../org/apache/logging/log4j/core/appender/AsyncAppender.java   | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/76067f2d/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 c9d8326..31bdfbf 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
@@ -111,7 +111,7 @@ public final class AsyncAppender extends AbstractAppender {
         } else if (errorRef == null) {
             throw new ConfigurationException("No appenders are available for AsyncAppender " + getName());
         }
-        asyncEventRouter = AsyncEventRouterFactory.create(queueSize);
+        asyncEventRouter = AsyncEventRouterFactory.create();
 
         thread.start();
         super.start();
@@ -160,8 +160,7 @@ public final class AsyncAppender extends AbstractAppender {
 
     private void logEvent(final Log4jLogEvent logEvent) {
         final Level logLevel = logEvent.getLevel();
-        final int remainingCapacity = getQueueRemainingCapacity();
-        final EventRoute route = asyncEventRouter.getRoute(thread.getId(), logLevel, queueSize, remainingCapacity);
+        final EventRoute route = asyncEventRouter.getRoute(thread.getId(), logLevel);
         route.logMessage(this, logEvent);
     }