diff options
author | Ivan Topolnak <itopolnak@despegar.com> | 2014-04-09 17:39:43 -0300 |
---|---|---|
committer | Ivan Topolnak <itopolnak@despegar.com> | 2014-04-09 17:39:43 -0300 |
commit | 98bb6b81e8f0f79ea42157e6c146cd8f795b3a6d (patch) | |
tree | bdda4baf6b401a27100948ea364886a084c0b9e2 /kamon-core/src/main/scala | |
parent | 55b3675a0b699c7a206131aea5bed6f4020c6906 (diff) | |
download | Kamon-98bb6b81e8f0f79ea42157e6c146cd8f795b3a6d.tar.gz Kamon-98bb6b81e8f0f79ea42157e6c146cd8f795b3a6d.tar.bz2 Kamon-98bb6b81e8f0f79ea42157e6c146cd8f795b3a6d.zip |
= core: adjust the assertions on ActorMetricsSpec accordingly to our current collection model
Diffstat (limited to 'kamon-core/src/main/scala')
-rw-r--r-- | kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala b/kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala index 87ad4f92..e52a66b2 100644 --- a/kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala +++ b/kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala @@ -18,9 +18,9 @@ package akka.instrumentation import org.aspectj.lang.annotation._ import org.aspectj.lang.ProceedingJoinPoint import akka.actor._ -import akka.dispatch.{Envelope, MessageDispatcher} +import akka.dispatch.{ Envelope, MessageDispatcher } import kamon.trace._ -import kamon.metrics.{ActorMetrics, Metrics} +import kamon.metrics.{ ActorMetrics, Metrics } import kamon.Kamon import kamon.metrics.ActorMetrics.ActorMetricRecorder import java.util.concurrent.atomic.AtomicInteger @@ -61,7 +61,7 @@ class BehaviourInvokeTracing { am.timeInMailbox.record(timestampBeforeProcessing - contextAndTimestamp.captureNanoTime) val currentMailboxSize = cellWithMetrics.queueSize.decrementAndGet() - if(currentMailboxSize >= 0) + if (currentMailboxSize >= 0) am.mailboxSize.record(currentMailboxSize) } } @@ -76,7 +76,7 @@ class BehaviourInvokeTracing { cellWithMetrics.actorMetricsRecorder.map { am ⇒ val currentMailboxSize = cellWithMetrics.queueSize.incrementAndGet() - if(currentMailboxSize >= 0) + if (currentMailboxSize >= 0) am.mailboxSize.record(currentMailboxSize) } } |