diff options
author | Diego <diegolparra@gmail.com> | 2014-04-23 13:38:11 -0300 |
---|---|---|
committer | Diego <diegolparra@gmail.com> | 2014-04-23 13:38:11 -0300 |
commit | 620ab1bab83254d0f49bd7c097dc2d0aa01d70da (patch) | |
tree | c8bae900e8070a3d0b8e0a546238faeb91b02695 /kamon-playground/src/main | |
parent | ced494db410a39a96e92d3dd376f8e9be4d309d6 (diff) | |
download | Kamon-620ab1bab83254d0f49bd7c097dc2d0aa01d70da.tar.gz Kamon-620ab1bab83254d0f49bd7c097dc2d0aa01d70da.tar.bz2 Kamon-620ab1bab83254d0f49bd7c097dc2d0aa01d70da.zip |
+ all: fix compilation issues
Diffstat (limited to 'kamon-playground/src/main')
-rw-r--r-- | kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala index 05859ee5..664bd4f9 100644 --- a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala +++ b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala @@ -23,13 +23,12 @@ import spray.httpx.RequestBuilding import scala.concurrent.{ Await, Future } import kamon.spray.KamonTraceDirectives import scala.util.Random -import akka.routing.RoundRobinRouter +import akka.routing.RoundRobinPool import kamon.trace.TraceRecorder import kamon.Kamon import kamon.metrics._ import spray.http.{ StatusCodes, Uri } import kamon.metrics.Subscriptions.TickMetricSnapshot -import kamon.newrelic.WebTransactionMetrics object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuilding with KamonTraceDirectives { import scala.concurrent.duration._ @@ -53,7 +52,7 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil implicit val timeout = Timeout(30 seconds) val pipeline = sendReceive - val replier = system.actorOf(Props[Replier].withRouter(RoundRobinRouter(nrOfInstances = 2)), "replier") + val replier = system.actorOf(Props[Replier].withRouter(RoundRobinPool(nrOfInstances = 2)), "replier") val random = new Random() val requestCountRecorder = Kamon(Metrics).register(CustomMetric("GetCount"), CustomMetric.histogram(10, 3, Scale.Unit)) |