Repository: logging-log4j2 Updated Branches: refs/heads/master 5141bf26c -> 710839d0e
Reduce test delays introduced in commit 96436fb958ce1f1a3d4f0c951f556f0709c91b15 from 3 seconds to 50 milliseconds. This reduces running this test case from 43 to 3 seconds. Watch this test in Jenkins to make sure it still passes. It runs fine over and over in Eclipse and 'mvn test -pl log4j-core -Dtest=KafkaAppenderTest' Project: http://git-wip-us.apache.org/repos/asf/logging-log4j2/repo Commit: http://git-wip-us.apache.org/repos/asf/logging-log4j2/commit/710839d0 Tree: http://git-wip-us.apache.org/repos/asf/logging-log4j2/tree/710839d0 Diff: http://git-wip-us.apache.org/repos/asf/logging-log4j2/diff/710839d0 Branch: refs/heads/master Commit: 710839d0e214e788eb62b7939f70e3f1089f5fc4 Parents: 5141bf2 Author: Gary Gregory <[email protected]> Authored: Mon Jan 22 21:43:42 2018 -0700 Committer: Gary Gregory <[email protected]> Committed: Mon Jan 22 21:43:42 2018 -0700 ---------------------------------------------------------------------- .../log4j/core/appender/mom/kafka/KafkaAppenderTest.java | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/logging-log4j2/blob/710839d0/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppenderTest.java ---------------------------------------------------------------------- diff --git a/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppenderTest.java b/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppenderTest.java index 115b76e..0c718b3 100644 --- a/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppenderTest.java +++ b/log4j-core/src/test/java/org/apache/logging/log4j/core/appender/mom/kafka/KafkaAppenderTest.java @@ -50,21 +50,16 @@ import static org.junit.Assert.*; public class KafkaAppenderTest { private static final MockProducer<byte[], byte[]> kafka = new MockProducer<byte[], byte[]>(true, null, null) { - @Override - public void close() { - try { - Thread.sleep(3000); - } catch (final InterruptedException ignore) { - } - } @Override public void close(final long timeout, final TimeUnit timeUnit) { try { - Thread.sleep(timeUnit.toMillis(timeout)); + Thread.sleep(50); } catch (final InterruptedException ignore) { + // ignore } } + }; private static final String LOG_MESSAGE = "Hello, world!";
