Remove critical event from the payload

agorapulse · May 29, 2024 · 30fcd4c · 30fcd4c
1 parent 1800b49
commit 30fcd4c
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/...relic/src/main/java/com/agorapulse/micronaut/newrelic/DefaultNewRelicInsightsService.java b/...relic/src/main/java/com/agorapulse/micronaut/newrelic/DefaultNewRelicInsightsService.java
@@ -97,6 +97,9 @@ public <E> void unsafeCreateEvents(@NonNull @Valid Collection<E> events) {
             .filter(EventPayloadExtractor::isNonCritical)
             .toList();
 
+        criticalEvents.forEach(event -> EventPayloadExtractor.removeCritical(event));
+        nonCriticalEvents.forEach(event -> EventPayloadExtractor.removeCritical(event));
+
         if (!criticalEvents.isEmpty()) {
             this.criticalClient.createEvents(criticalEvents);
         }

diff --git a/...onaut-newrelic/src/main/java/com/agorapulse/micronaut/newrelic/EventPayloadExtractor.java b/...onaut-newrelic/src/main/java/com/agorapulse/micronaut/newrelic/EventPayloadExtractor.java
@@ -29,6 +29,10 @@ static boolean isNonCritical(Map<String, Object> payload) {
         return !isCritical(payload);
     }
 
+    static void removeCritical(Map<String, Object> event) {
+        event.remove("critical");
+    }
+
     /**
      * Extracts the paylaod for the event.
      *