diff --git a/libs/micronaut-newrelic/src/main/java/com/agorapulse/micronaut/newrelic/DefaultNewRelicInsightsService.java b/libs/micronaut-newrelic/src/main/java/com/agorapulse/micronaut/newrelic/DefaultNewRelicInsightsService.java index 8dc49a2..ef2e92e 100644 --- a/libs/micronaut-newrelic/src/main/java/com/agorapulse/micronaut/newrelic/DefaultNewRelicInsightsService.java +++ b/libs/micronaut-newrelic/src/main/java/com/agorapulse/micronaut/newrelic/DefaultNewRelicInsightsService.java @@ -97,6 +97,9 @@ public void unsafeCreateEvents(@NonNull @Valid Collection 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/libs/micronaut-newrelic/src/main/java/com/agorapulse/micronaut/newrelic/EventPayloadExtractor.java b/libs/micronaut-newrelic/src/main/java/com/agorapulse/micronaut/newrelic/EventPayloadExtractor.java index 7272e8e..50dca48 100644 --- a/libs/micronaut-newrelic/src/main/java/com/agorapulse/micronaut/newrelic/EventPayloadExtractor.java +++ b/libs/micronaut-newrelic/src/main/java/com/agorapulse/micronaut/newrelic/EventPayloadExtractor.java @@ -29,6 +29,10 @@ static boolean isNonCritical(Map payload) { return !isCritical(payload); } + static void removeCritical(Map event) { + event.remove("critical"); + } + /** * Extracts the paylaod for the event. *