Fix bulid warnings

graylog-labs · Apr 13, 2017 · f50057f · f50057f
1 parent 99e6517
commit f50057f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/src/main/java/org/graylog/plugins/internallogs/codec/SerializedLogEventCodec.java b/src/main/java/org/graylog/plugins/internallogs/codec/SerializedLogEventCodec.java
@@ -134,9 +134,7 @@ private Message processLogEvent(LogEvent logEvent) {
         }
 
         if (includeThreadContext) {
-            for (Map.Entry<String, String> entry : logEvent.getContextMap().entrySet()) {
-                message.addField("context_" + entry.getKey(), entry.getValue());
-            }
+            logEvent.getContextData().forEach((k, v ) -> message.addField("context_" + k, v));
 
             // Guard against https://issues.apache.org/jira/browse/LOG4J2-1530
             final ThreadContext.ContextStack contextStack = logEvent.getContextStack();

diff --git a/src/test/java/org/graylog/plugins/internallogs/log4j/DirectConsumingAppenderTest.java b/src/test/java/org/graylog/plugins/internallogs/log4j/DirectConsumingAppenderTest.java
@@ -82,7 +82,7 @@ public void appenderUsesThresholdFilter() throws Exception {
         assertThat(appender.getFilter()).isInstanceOf(ThresholdFilter.class);
     }
 
-    private final class TestConsumer implements Consumer<byte[]> {
+    private static final class TestConsumer implements Consumer<byte[]> {
         private final List<byte[]> processedLogEvents = new ArrayList<>();
 
         @Override