This is an automated email from the ASF dual-hosted git repository. lburgazzoli pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 72bc2f1891095235fd3f8e291927fe247bb44039 Author: Luca Burgazzoli <lburgazz...@gmail.com> AuthorDate: Thu Oct 15 12:21:11 2020 +0200 TaskHelperTest: cleanup MyLogger class --- .../org/apache/camel/kafkaconnector/utils/TaskHelperTest.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/core/src/test/java/org/apache/camel/kafkaconnector/utils/TaskHelperTest.java b/core/src/test/java/org/apache/camel/kafkaconnector/utils/TaskHelperTest.java index f8e4758..8cb949f 100644 --- a/core/src/test/java/org/apache/camel/kafkaconnector/utils/TaskHelperTest.java +++ b/core/src/test/java/org/apache/camel/kafkaconnector/utils/TaskHelperTest.java @@ -176,8 +176,8 @@ public class TaskHelperTest { assertThat(logger.getEvents().poll()).isNotNull().contains(partName); } - class MyLogger extends LoggerWrapper { - private Queue<String> events = new ConcurrentLinkedQueue<String>(); + static class MyLogger extends LoggerWrapper { + private final Queue<String> events = new ConcurrentLinkedQueue<>(); public MyLogger(Logger logger, String fqcn) { super(logger, fqcn); @@ -188,9 +188,7 @@ public class TaskHelperTest { } private void log(LoggingLevel level, String msg) { - StringBuilder sb = new StringBuilder() - .append(level).append(" ").append(msg); - events.add(sb.toString()); + events.add(level + " " + msg); } @Override