From 432706dca9aac94fad9a38a4830d9399337a6a5a Mon Sep 17 00:00:00 2001 From: Simon Schneider <10846939+raynigon@users.noreply.github.com> Date: Mon, 7 Nov 2022 11:58:20 +0100 Subject: [PATCH] Format Source Name --- .../ecs/logging/async/service/DefaultAsyncService.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/ecs-logging-async/src/main/java/com/raynigon/ecs/logging/async/service/DefaultAsyncService.java b/ecs-logging-async/src/main/java/com/raynigon/ecs/logging/async/service/DefaultAsyncService.java index 9e8ced1..313ab3e 100644 --- a/ecs-logging-async/src/main/java/com/raynigon/ecs/logging/async/service/DefaultAsyncService.java +++ b/ecs-logging-async/src/main/java/com/raynigon/ecs/logging/async/service/DefaultAsyncService.java @@ -28,7 +28,7 @@ public class DefaultAsyncService implements AsyncService { @Override public CompletableFuture supplyAsync(Supplier supplier) { - String sourceName = supplier.getClass().getName(); + String sourceName = formatSource(supplier.getClass()); Timer queueTimer = meterRegistry.timer(QUEUE_TIMER_NAME, "source", sourceName); Timer execTimer = meterRegistry.timer(EXECUTION_TIMER_NAME, "source", sourceName); Timer.Sample sample = Timer.start(); @@ -43,7 +43,7 @@ public CompletableFuture supplyAsync(Supplier supplier) { @Override public ForkJoinTask submit(Callable callable) { - String sourceName = callable.getClass().getName(); + String sourceName = formatSource(callable.getClass()); Timer queueTimer = meterRegistry.timer(QUEUE_TIMER_NAME, "source", sourceName); Timer execTimer = meterRegistry.timer(EXECUTION_TIMER_NAME, "source", sourceName); Timer.Sample sample = Timer.start(); @@ -54,4 +54,8 @@ public ForkJoinTask submit(Callable callable) { }; return forkJoinPool.submit(wrapped); } + + private String formatSource(Class source){ + return source.getName().split("/")[0]; + } }