From 42e23d23ba64f570ad613bca26d930727cd77dde Mon Sep 17 00:00:00 2001
From: Ivan Topolnak <itopolnak@despegar.com>
Date: Wed, 9 Apr 2014 17:39:43 -0300
Subject: = core: adjust the assertions on ActorMetricsSpec accordingly to our
 current collection model

---
 .../scala/akka/instrumentation/ActorMessagePassingTracing.scala   | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

(limited to 'kamon-core/src/main')

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)
     }
   }
-- 
cgit v1.2.3