You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ji...@apache.org on 2024/03/14 14:02:51 UTC
(camel-quarkus) 23/26: Micrometer more debug logging 02
This is an automated email from the ASF dual-hosted git repository.
jiriondrusek pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 34a713fcba947f0e84b2b0ac4d5e18c18d7577ad
Author: JiriOndrusek <on...@gmail.com>
AuthorDate: Wed Mar 13 14:30:34 2024 +0100
Micrometer more debug logging 02
---
.../quarkus/component/micrometer/it/MicrometerResource.java | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git a/integration-tests/micrometer/src/main/java/org/apache/camel/quarkus/component/micrometer/it/MicrometerResource.java b/integration-tests/micrometer/src/main/java/org/apache/camel/quarkus/component/micrometer/it/MicrometerResource.java
index 4e5cb3067a..4eafe512bf 100644
--- a/integration-tests/micrometer/src/main/java/org/apache/camel/quarkus/component/micrometer/it/MicrometerResource.java
+++ b/integration-tests/micrometer/src/main/java/org/apache/camel/quarkus/component/micrometer/it/MicrometerResource.java
@@ -185,6 +185,15 @@ public class MicrometerResource {
if (service.getMeterRegistry() instanceof CompositeMeterRegistry) {
LOG.info("composite registry from " + ((CompositeMeterRegistry) service.getMeterRegistry()).getRegistries());
}
+ LOG.info("Searching for the `camel.routes.added` in single registries.");
+ ((CompositeMeterRegistry) service.getMeterRegistry()).getRegistries().forEach(mr -> {
+ Optional<Meter> o = mr.getMeters().stream().filter(m -> m.getId().getName().equals("camel.routes.added")).findAny();
+ LOG.info("`camel.routes.added` present in " + mr + ": " + o.isPresent());
+ if (o.isPresent()) {
+ LOG.info(" with value " + o.get().measure().iterator().next());
+ }
+ });
+
Optional<Meter> om = service.getMeterRegistry().getMeters().stream()
.filter(m -> m.getId().getName().contains("camel.routes.added")).findFirst();
LOG.info("meter `camel.routes.added` " + om.get());