Use @Metered CDI interceptor
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/1a8fc045 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1a8fc045 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1a8fc045 Branch: refs/heads/master Commit: 1a8fc04534741f847847b3ca2f06ee6809331f5f Parents: 0e0d6e9 Author: Antonin Stefanutti <anto...@stefanutti.fr> Authored: Fri Feb 12 12:11:01 2016 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Feb 12 13:46:14 2016 +0100 ---------------------------------------------------------------------- .../apache/camel/example/cdi/metrics/Application.java | 1 + .../camel/example/cdi/metrics/UnreliableService.java | 11 +++-------- 2 files changed, 4 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/1a8fc045/examples/camel-example-cdi-metrics/src/main/java/org/apache/camel/example/cdi/metrics/Application.java ---------------------------------------------------------------------- diff --git a/examples/camel-example-cdi-metrics/src/main/java/org/apache/camel/example/cdi/metrics/Application.java b/examples/camel-example-cdi-metrics/src/main/java/org/apache/camel/example/cdi/metrics/Application.java index 423f9c7..8056365 100644 --- a/examples/camel-example-cdi-metrics/src/main/java/org/apache/camel/example/cdi/metrics/Application.java +++ b/examples/camel-example-cdi-metrics/src/main/java/org/apache/camel/example/cdi/metrics/Application.java @@ -77,6 +77,7 @@ class Application { .log("Processing ${body}...") // The 'generated' meter .to("metrics:meter:generated") + // The 'attempt' meter via @Metered interceptor .bean(UnreliableService.class) .filter(header(Exchange.REDELIVERED)) .log(LoggingLevel.WARN, "Processed ${body} after ${header.CamelRedeliveryCounter} retries") http://git-wip-us.apache.org/repos/asf/camel/blob/1a8fc045/examples/camel-example-cdi-metrics/src/main/java/org/apache/camel/example/cdi/metrics/UnreliableService.java ---------------------------------------------------------------------- diff --git a/examples/camel-example-cdi-metrics/src/main/java/org/apache/camel/example/cdi/metrics/UnreliableService.java b/examples/camel-example-cdi-metrics/src/main/java/org/apache/camel/example/cdi/metrics/UnreliableService.java index 2da6320..7e8b0d5 100644 --- a/examples/camel-example-cdi-metrics/src/main/java/org/apache/camel/example/cdi/metrics/UnreliableService.java +++ b/examples/camel-example-cdi-metrics/src/main/java/org/apache/camel/example/cdi/metrics/UnreliableService.java @@ -18,21 +18,16 @@ package org.apache.camel.example.cdi.metrics; import javax.enterprise.context.ApplicationScoped; -import javax.inject.Inject; -import com.codahale.metrics.Meter; +import com.codahale.metrics.annotation.Metered; import org.apache.camel.Exchange; import org.apache.camel.RuntimeExchangeException; @ApplicationScoped public class UnreliableService { - @Inject - private Meter attempt; - - public void unreliable(Exchange exchange) { - attempt.mark(); - + @Metered + public void attempt(Exchange exchange) { if (Math.random() < 0.5) { throw new RuntimeExchangeException("Random failure", exchange); }
