diff options
-rw-r--r-- | kamon-play/src/test/scala/kamon/play/RequestInstrumentationSpec.scala | 12 | ||||
-rw-r--r-- | kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala | 4 |
2 files changed, 8 insertions, 8 deletions
diff --git a/kamon-play/src/test/scala/kamon/play/RequestInstrumentationSpec.scala b/kamon-play/src/test/scala/kamon/play/RequestInstrumentationSpec.scala index baa5cd74..976e7bc0 100644 --- a/kamon-play/src/test/scala/kamon/play/RequestInstrumentationSpec.scala +++ b/kamon-play/src/test/scala/kamon/play/RequestInstrumentationSpec.scala @@ -225,16 +225,16 @@ object Routes extends Router.Routes { def routes: PartialFunction[RequestHeader, Handler] = { case Application_getRouted(params) ⇒ call { - createInvoker(controllers.Application.getRouted, - HandlerDef(this.getClass.getClassLoader, "", "controllers.Application", "getRouted", Nil, "GET", """some comment""", Routes.prefix + """getRouted""")).call(controllers.Application.getRouted) + invokeHandler(controllers.Application.getRouted, + HandlerDef(this, "controllers.Application", "getRouted", Nil, "GET", """some comment""", Routes.prefix + """getRouted""")) } case Application_postRouted(params) ⇒ call { - createInvoker(controllers.Application.postRouted, - HandlerDef(this.getClass.getClassLoader, "", "controllers.Application", "postRouted", Nil, "POST", """some comment""", Routes.prefix + """postRouted""")).call(controllers.Application.postRouted) + invokeHandler(controllers.Application.postRouted, + HandlerDef(this, "controllers.Application", "postRouted", Nil, "POST", """some comment""", Routes.prefix + """postRouted""")) } case Application_show(params) ⇒ call(params.fromPath[Int]("id", None)) { (id) ⇒ - createInvoker(controllers.Application.showRouted(id), - HandlerDef(this.getClass.getClassLoader, "", "controllers.Application", "showRouted", Seq(classOf[Int]), "GET", """""", Routes.prefix + """show/some/$id<[^/]+>""")).call(controllers.Application.showRouted(id)) + invokeHandler(controllers.Application.showRouted(id), + HandlerDef(this, "controllers.Application", "showRouted", Seq(classOf[Int]), "GET", """some comment""", Routes.prefix + """show/some/$id<[^/]+>""")) } } } diff --git a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala index 878c3c8c..af1eb793 100644 --- a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala +++ b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala @@ -17,7 +17,7 @@ package test import akka.actor._ -import akka.routing.RoundRobinPool +import akka.routing.RoundRobinRouter import akka.util.Timeout import kamon.Kamon import kamon.metric.Subscriptions.TickMetricSnapshot @@ -67,7 +67,7 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil //Kamon(UserMetrics).registerGauge("test-gauge")(() => 10L) val pipeline = sendReceive - val replier = system.actorOf(Props[Replier].withRouter(RoundRobinPool(nrOfInstances = 4)), "replier") + val replier = system.actorOf(Props[Replier].withRouter(RoundRobinRouter(nrOfInstances = 4)), "replier") val random = new Random() |