Repository: logging-log4j2 Updated Branches: refs/heads/master e21f7a873 -> 58105fd61
LOG4J2-1422 verify that CountingAsyncQueueFullPolicy is correctly installed (or the BlockingAppender shutdown flag is never set) Project: http://git-wip-us.apache.org/repos/asf/logging-log4j2/repo Commit: http://git-wip-us.apache.org/repos/asf/logging-log4j2/commit/d8a40705 Tree: http://git-wip-us.apache.org/repos/asf/logging-log4j2/tree/d8a40705 Diff: http://git-wip-us.apache.org/repos/asf/logging-log4j2/diff/d8a40705 Branch: refs/heads/master Commit: d8a40705091f50049a762ef0fae618e756aeda51 Parents: e21f7a8 Author: rpopma <[email protected]> Authored: Sat Jun 11 02:35:00 2016 +0900 Committer: rpopma <[email protected]> Committed: Sat Jun 11 02:35:00 2016 +0900 ---------------------------------------------------------------------- .../log4j/core/appender/AsyncAppenderQueueFullPolicyTest.java | 7 +++++++ 1 file changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/d8a40705/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/AsyncAppenderQueueFullPolicyTest.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/AsyncAppenderQueueFullPolicyTest.java b/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/AsyncAppenderQueueFullPolicyTest.java index b271d70..452bf72 100644 --- a/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/AsyncAppenderQueueFullPolicyTest.java +++ b/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/AsyncAppenderQueueFullPolicyTest.java @@ -16,6 +16,7 @@ */ package org.apache.logging.log4j.core.appender; +import java.lang.reflect.Field; import java.util.concurrent.atomic.AtomicLong; import org.apache.logging.log4j.Level; @@ -76,6 +77,12 @@ public class AsyncAppenderQueueFullPolicyTest { public void testRouter() throws Exception { final Logger logger = LogManager.getLogger(AsyncAppenderQueueFullPolicyTest.class); + Field field = AsyncAppender.class.getDeclaredField("asyncQueueFullPolicy"); + field.setAccessible(true); + Object policy = field.get(asyncAppender); + assertEquals("CountingAsyncQueueFullPolicy installed correctly", + CountingAsyncQueueFullPolicy.class, policy.getClass()); + assertEquals(3, asyncAppender.getQueueCapacity()); logger.error("event 1 - gets taken off the queue"); logger.warn("event 2");
