You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2022/12/19 13:25:37 UTC
[camel] branch main updated: CAMEL-18752: camel-micrometer - Include description of metrics
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 7bda1236434 CAMEL-18752: camel-micrometer - Include description of metrics
7bda1236434 is described below
commit 7bda1236434f843cf4e59f1be49768c02b134e78
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Mon Dec 19 14:19:51 2022 +0100
CAMEL-18752: camel-micrometer - Include description of metrics
---
.../eventnotifier/MicrometerExchangeEventNotifier.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
diff --git a/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/eventnotifier/MicrometerExchangeEventNotifier.java b/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/eventnotifier/MicrometerExchangeEventNotifier.java
index 265bfd76973..d4fc998b69f 100644
--- a/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/eventnotifier/MicrometerExchangeEventNotifier.java
+++ b/components/camel-micrometer/src/main/java/org/apache/camel/component/micrometer/eventnotifier/MicrometerExchangeEventNotifier.java
@@ -67,10 +67,10 @@ public class MicrometerExchangeEventNotifier extends AbstractMicrometerEventNoti
public void notify(CamelEvent eventObject) {
if (!(getIgnoreExchanges().test(((ExchangeEvent) eventObject).getExchange()))) {
handleExchangeEvent((ExchangeEvent) eventObject);
- if (eventObject instanceof ExchangeSentEvent) {
- handleSentEvent((ExchangeSentEvent) eventObject);
- } else if (eventObject instanceof ExchangeCreatedEvent) {
+ if (eventObject instanceof ExchangeCreatedEvent) {
handleCreatedEvent((ExchangeCreatedEvent) eventObject);
+ } else if (eventObject instanceof ExchangeSentEvent) {
+ handleSentEvent((ExchangeSentEvent) eventObject);
} else if (eventObject instanceof ExchangeCompletedEvent || eventObject instanceof ExchangeFailedEvent) {
handleDoneEvent((ExchangeEvent) eventObject);
}
@@ -92,7 +92,9 @@ public class MicrometerExchangeEventNotifier extends AbstractMicrometerEventNoti
protected void handleSentEvent(ExchangeSentEvent sentEvent) {
String name = namingStrategy.getName(sentEvent.getExchange(), sentEvent.getEndpoint());
Tags tags = namingStrategy.getTags(sentEvent, sentEvent.getEndpoint());
- getMeterRegistry().timer(name, tags).record(sentEvent.getTimeTaken(), TimeUnit.MILLISECONDS);
+ Timer timer = Timer.builder(name).tags(tags).description("Time taken to send message to the endpoint")
+ .register(getMeterRegistry());
+ timer.record(sentEvent.getTimeTaken(), TimeUnit.MILLISECONDS);
}
protected void handleCreatedEvent(ExchangeCreatedEvent createdEvent) {