Add version field to GelfMessage #260

* Add version field Add version field for GELF versions 1.1 and up as specified here: https://docs.graylog.org/en/latest/pages/gelf.html > version string (UTF-8) > GELF spec version – “1.1”; MUST be set by client library. * Unit test added unit test for version field
mp911de · Mar 1, 2021 · 2e231c7 · 2e231c7
1 parent 3b74daf
commit 2e231c7
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/src/main/java/biz/paluch/logging/gelf/intern/GelfMessage.java b/src/main/java/biz/paluch/logging/gelf/intern/GelfMessage.java
@@ -37,6 +37,7 @@ public class GelfMessage {
     public static final String FIELD_TIMESTAMP = "timestamp";
     public static final String FIELD_LEVEL = "level";
     public static final String FIELD_FACILITY = "facility";
+    public static final String FIELD_VERSION = "version";
     public static final String ID_NAME = "id";
 
     /**
@@ -154,6 +155,10 @@ protected void toJson(OutputAccessor out, String additionalFieldPrefix) {
 
         boolean hasFields = writeIfNotEmpty(out, false, FIELD_HOST, getHost());
 
+        if (!isEmpty(version) && !GELF_VERSION_1_0.equals(version)) {
+            hasFields = writeIfNotEmpty(out, hasFields, FIELD_VERSION, version);
+        }
+
         if (!isEmpty(shortMessage)) {
             hasFields = writeIfNotEmpty(out, hasFields, FIELD_SHORT_MESSAGE, getShortMessage());
         }

diff --git a/src/test/java/biz/paluch/logging/gelf/intern/GelfMessageUnitTests.java b/src/test/java/biz/paluch/logging/gelf/intern/GelfMessageUnitTests.java
@@ -236,6 +236,7 @@ void testGelf_v1_1() {
         assertThat(gelfMessage.getVersion()).isEqualTo(GelfMessage.GELF_VERSION_1_1);
         assertThat(gelfMessage.toJson()).contains("\"level\":6");
         assertThat(gelfMessage.toJson()).contains("\"timestamp\":123.456");
+        assertThat(gelfMessage.toJson()).contains("\"version\":\"1.1\"");
 
     }