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 | d3976b2b46f8fed2d748f4b7539ee466e18b597b (patch) | |
tree | 1ff6bbcbdd52d255f321a3df7491822a2e6385c7 /kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala | |
parent | d072dbf8df995840f071e08b9daeefbed6285857 (diff) | |
download | Kamon-d3976b2b46f8fed2d748f4b7539ee466e18b597b.tar.gz Kamon-d3976b2b46f8fed2d748f4b7539ee466e18b597b.tar.bz2 Kamon-d3976b2b46f8fed2d748f4b7539ee466e18b597b.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) } } } |