wip

1 files changed, 15 insertions, 2 deletions

diff --git a/src/test/scala/kamon/instrumentation/DispatcherInstrumentationSpec.scala b/src/test/scala/kamon/instrumentation/DispatcherInstrumentationSpec.scala
index d72989f6..7a14af6c 100644
--- a/src/test/scala/kamon/instrumentation/DispatcherInstrumentationSpec.scala
+++ b/src/test/scala/kamon/instrumentation/DispatcherInstrumentationSpec.scala
@@ -1,14 +1,21 @@
 package kamon.instrumentation
 
 import org.scalatest.{Matchers, WordSpec}
-import akka.actor.ActorSystem
+import akka.actor.{Actor, Props, ActorSystem}
 import kamon.metric.MetricDirectory
+import kamon.Kamon
 
 class DispatcherInstrumentationSpec extends WordSpec with Matchers{
 
 
   "the dispatcher instrumentation" should {
-    "instrument a dispatcher that belongs to a non-filtered actor system" in {
+    "instrument a dispatcher that belongs to a non-filtered actor system" in new SingleDispatcherActorSystem {
+      val x = Kamon.Metric.actorSystem("single-dispatcher").get.dispatchers
+      (1 to 10).foreach(actor ! _)
+
+      val active = x.get("akka.actor.default-dispatcher").activeThreadCount.snapshot
+      println("Active max: "+active.max)
+      println("Active min: "+active.min)
 
     }
   }
@@ -16,6 +23,12 @@ class DispatcherInstrumentationSpec extends WordSpec with Matchers{
 
   trait SingleDispatcherActorSystem {
     val actorSystem = ActorSystem("single-dispatcher")
+    val actor = actorSystem.actorOf(Props(new Actor {
+      def receive = {
+        case a => sender ! a; println("BAAAANG")
+      }
+    }))
+
   }
 }