aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/akka/instrumentation
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-core/src/main/scala/akka/instrumentation')
-rw-r--r--kamon-core/src/main/scala/akka/instrumentation/ActorMessagePassingTracing.scala8
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)
}
}