diff options
author | Diego <diegolparra@gmail.com> | 2014-04-02 18:16:09 -0300 |
---|---|---|
committer | Diego <diegolparra@gmail.com> | 2014-04-02 20:12:40 -0300 |
commit | d76d5a6f445278e686fc7484edbdb61483971b23 (patch) | |
tree | a0853aaced601c553af5ddc5c8e11cd9d111ae57 /kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala | |
parent | 733e5dcd98e1e8c83a4b315fdb6eca3fb761ecc7 (diff) | |
download | Kamon-d76d5a6f445278e686fc7484edbdb61483971b23.tar.gz Kamon-d76d5a6f445278e686fc7484edbdb61483971b23.tar.bz2 Kamon-d76d5a6f445278e686fc7484edbdb61483971b23.zip |
refactor
Diffstat (limited to 'kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala')
-rw-r--r-- | kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala b/kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala index 4e0f0dfe..a0af09bb 100644 --- a/kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala +++ b/kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala @@ -18,9 +18,9 @@ package kamon.statsd import akka.actor._ import kamon.Kamon -import kamon.statsd.client.StatsdMetricsSender import kamon.metrics.Subscriptions.TickMetricSnapshot -import kamon.metrics.{CustomMetric, TraceMetrics, Metrics} +import kamon.metrics.{TickMetricSnapshotBuffer, CustomMetric, TraceMetrics, Metrics} +import kamon.statsd.StatsdMetricsSender object Statsd extends ExtensionId[StatsdExtension] with ExtensionIdProvider { override def lookup(): ExtensionId[_ <: Extension] = Statsd @@ -46,7 +46,9 @@ class StatsdMetricsListener(host:String, port:Int, prefix:String) extends Actor log.info("Starting the Kamon(Statsd) extension") - val statsdActor = context.actorOf(StatsdMetricsSender.props(prefix, new InetSocketAddress(InetAddress.getByName(host), port)), "StatsdSender") + val statsdActor = context.actorOf(StatsdMetricsSender.props(prefix, new InetSocketAddress(InetAddress.getByName(host), port)), "statsd-metrics-sender") + val translator = context.actorOf(StatsdMetricTranslator.props(statsdActor), "statsd-metrics-translator") + val buffer = context.actorOf(TickMetricSnapshotBuffer.props(1 minute, translator), "metrics-buffer") def receive = { case tick: TickMetricSnapshot ⇒ statsdActor.forward(tick) |