= core: adjust the assertions on ActorMetricsSpec accordingly to our current collection model

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)
     }
   }