upgrading to akka 2.2

1 files changed, 34 insertions, 0 deletions

diff --git a/kamon-core/src/test/scala/kamon/instrumentation/DispatcherInstrumentationSpec.scala b/kamon-core/src/test/scala/kamon/instrumentation/DispatcherInstrumentationSpec.scala
new file mode 100644
index 00000000..89ef61f3
--- /dev/null
+++ b/kamon-core/src/test/scala/kamon/instrumentation/DispatcherInstrumentationSpec.scala
@@ -0,0 +1,34 @@
+package kamon.instrumentation
+
+import org.scalatest.{Matchers, WordSpec}
+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 new SingleDispatcherActorSystem {
+      val x = Kamon.Metric.actorSystem("single-dispatcher").get.dispatchers
+      (1 to 10).foreach(actor ! _)
+
+      val active = x.get("akka.actor.default-dispatcher").get.activeThreadCount.snapshot
+      println("Active max: "+active.max)
+      println("Active min: "+active.min)
+
+    }
+  }
+
+
+  trait SingleDispatcherActorSystem {
+    val actorSystem = ActorSystem("single-dispatcher")
+    val actor = actorSystem.actorOf(Props(new Actor {
+      def receive = {
+        case a => sender ! a;
+      }
+    }))
+
+  }
+}
+