You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by lb...@apache.org on 2020/10/15 13:45:54 UTC
[camel-kafka-connector] 03/06: TaskHelperTest: cleanup MyLogger
class
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 <lb...@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