diff options
Diffstat (limited to 'kamon-core/src/main')
-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) } } |