diff options
author | Ivan Topolnak <itopolnak@despegar.com> | 2014-05-21 18:17:30 -0300 |
---|---|---|
committer | Ivan Topolnak <itopolnak@despegar.com> | 2014-05-21 18:17:30 -0300 |
commit | 5596e6061115307dcbf5b34c4181b201c103fc72 (patch) | |
tree | a3dd046970e836109c0dca584e120609bf78992b /kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala | |
parent | e9360c1e67b653614b7c65866f98c0db620a6f63 (diff) | |
download | Kamon-5596e6061115307dcbf5b34c4181b201c103fc72.tar.gz Kamon-5596e6061115307dcbf5b34c4181b201c103fc72.tar.bz2 Kamon-5596e6061115307dcbf5b34c4181b201c103fc72.zip |
= core: avoid using tuples in favor of case classes
Diffstat (limited to 'kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala')
-rw-r--r-- | kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala b/kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala index 20bfe564..6db86828 100644 --- a/kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala +++ b/kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala @@ -24,7 +24,8 @@ import kamon.trace._ import kamon.metrics.{ ActorMetrics, Metrics } import kamon.Kamon import kamon.metrics.ActorMetrics.ActorMetricRecorder -import kamon.metrics.instruments.counter.MinMaxCounter +import kamon.metrics.instruments.MinMaxCounter +import kamon.metrics.instruments.MinMaxCounter.CounterMeasurement @Aspect class BehaviourInvokeTracing { @@ -46,11 +47,11 @@ class BehaviourInvokeTracing { cellWithMetrics.mailboxSizeCollectorCancellable = metricsExtension.scheduleGaugeRecorder { cellWithMetrics.actorMetricsRecorder.map { am ⇒ import am.mailboxSize._ - val (min, max, sum) = cellWithMetrics.queueSize.collect() + val CounterMeasurement(min, max, current) = cellWithMetrics.queueSize.collect() record(min) record(max) - record(sum) + record(current) } } } |