fix-no-uuid in eventContext.getEventData().getMessageId() (#22)

teragrep · May 15, 2024 · c0d3386 · c0d3386
1 parent 89051d3
commit c0d3386
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/src/main/java/com/teragrep/aer_01/EventContextConsumer.java b/src/main/java/com/teragrep/aer_01/EventContextConsumer.java
@@ -59,6 +59,7 @@
 import java.net.UnknownHostException;
 import java.nio.charset.StandardCharsets;
 import java.time.Instant;
+import java.util.UUID;
 import java.util.function.Consumer;
 
 final class EventContextConsumer implements AutoCloseable, Consumer<EventContext> {
@@ -96,9 +97,17 @@ private String getRealHostName() {
 
     @Override
     public void accept(EventContext eventContext) {
+
+        String eventUuid = eventContext.getEventData().getMessageId();
+
+        // FIXME proper handling of non-provided uuids
+        if (eventUuid == null) {
+            eventUuid = "aer_01="+UUID.randomUUID();
+        }
+
         SDElement sdId = new SDElement("event_id@48577")
                 .addSDParam("hostname", realHostName)
-                .addSDParam("uuid", eventContext.getEventData().getMessageId())
+                .addSDParam("uuid", eventUuid)
                 .addSDParam("unixtime", Instant.now().toString())
                 .addSDParam("id_source", "source");
         /*