From 7307e1cc97e0363d1fb4cc116fc69a5272ca3730 Mon Sep 17 00:00:00 2001 From: Ivan Topolnak Date: Tue, 4 Feb 2014 15:58:30 -0300 Subject: metrics buffer for easier periodic reporting --- kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'kamon-playground/src/main/scala') diff --git a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala index cd497ca5..fb3d05d2 100644 --- a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala +++ b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala @@ -25,7 +25,7 @@ import scala.util.Random import akka.routing.RoundRobinRouter import kamon.trace.TraceRecorder import kamon.Kamon -import kamon.metrics.{ ActorMetrics, TraceMetrics, Metrics } +import kamon.metrics.{TickMetricSnapshotBuffer, ActorMetrics, TraceMetrics, Metrics} import spray.http.{ StatusCodes, Uri } import kamon.metrics.Subscriptions.TickMetricSnapshot import kamon.newrelic.WebTransactionMetrics @@ -44,7 +44,9 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil def receive: Actor.Receive = { case any ⇒ sender ! any } }), "com") - Kamon(Metrics).subscribe(TraceMetrics, "*", printer, permanently = true) + val buffer = system.actorOf(TickMetricSnapshotBuffer.props(10 seconds, printer)) + + Kamon(Metrics).subscribe(TraceMetrics, "*", buffer, permanently = true) //Kamon(Metrics).subscribe(ActorMetrics, "*", printer, permanently = true) implicit val timeout = Timeout(30 seconds) -- cgit v1.2.3