aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala
diff options
context:
space:
mode:
authorIvan Topolnak <itopolnak@despegar.com>2014-05-21 18:17:30 -0300
committerIvan Topolnak <itopolnak@despegar.com>2014-05-21 18:17:30 -0300
commit5596e6061115307dcbf5b34c4181b201c103fc72 (patch)
treea3dd046970e836109c0dca584e120609bf78992b /kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala
parente9360c1e67b653614b7c65866f98c0db620a6f63 (diff)
downloadKamon-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.scala7
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)
}
}
}