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/gelf-layout-gc-free Commit: 76067f2d9e8b32fe305a650aa821b77797791a03 Parents: e91ea51 Author: rpopma <rpo...@apache.org> Authored: Tue Mar 15 01:59:10 2016 +1100 Committer: rpopma <rpo...@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); }
