diff options
author | Diego <diegolparra@gmail.com> | 2014-04-02 18:52:27 -0300 |
---|---|---|
committer | Diego <diegolparra@gmail.com> | 2014-04-02 20:12:40 -0300 |
commit | 7e2cf36025c697116a232b966986cbf4f2f76b01 (patch) | |
tree | b8a515817aa7745ef1fbf000838d7350a666c700 /kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala | |
parent | d76d5a6f445278e686fc7484edbdb61483971b23 (diff) | |
download | Kamon-7e2cf36025c697116a232b966986cbf4f2f76b01.tar.gz Kamon-7e2cf36025c697116a232b966986cbf4f2f76b01.tar.bz2 Kamon-7e2cf36025c697116a232b966986cbf4f2f76b01.zip |
WIP:statsd module
Diffstat (limited to 'kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala')
-rw-r--r-- | kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala | 14 |
1 files changed, 6 insertions, 8 deletions
diff --git a/kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala b/kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala index a0af09bb..786e518b 100644 --- a/kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala +++ b/kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala @@ -19,8 +19,7 @@ package kamon.statsd import akka.actor._ import kamon.Kamon import kamon.metrics.Subscriptions.TickMetricSnapshot -import kamon.metrics.{TickMetricSnapshotBuffer, CustomMetric, TraceMetrics, Metrics} -import kamon.statsd.StatsdMetricsSender +import kamon.metrics.{ TickMetricSnapshotBuffer, CustomMetric, TraceMetrics, Metrics } object Statsd extends ExtensionId[StatsdExtension] with ExtensionIdProvider { override def lookup(): ExtensionId[_ <: Extension] = Statsd @@ -32,8 +31,8 @@ class StatsdExtension(private val system: ExtendedActorSystem) extends Kamon.Ext private val config = system.settings.config.getConfig("kamon.statsd") val hostname = config.getString("hostname") - val port = config.getInt("port") - val prefix = config.getString("prefix") + val port = config.getInt("port") + val prefix = config.getString("prefix") val statsdMetricsListener = system.actorOf(Props(new StatsdMetricsListener(hostname, port, prefix)), "kamon-statsd-metrics-listener") @@ -41,12 +40,12 @@ class StatsdExtension(private val system: ExtendedActorSystem) extends Kamon.Ext Kamon(Metrics)(system).subscribe(CustomMetric, "*", statsdMetricsListener, permanently = true) } -class StatsdMetricsListener(host:String, port:Int, prefix:String) extends Actor with ActorLogging { - import java.net.{InetAddress, InetSocketAddress} +class StatsdMetricsListener(host: String, port: Int, prefix: String) extends Actor with ActorLogging { + import java.net.{ InetAddress, InetSocketAddress } log.info("Starting the Kamon(Statsd) extension") - val statsdActor = context.actorOf(StatsdMetricsSender.props(prefix, new InetSocketAddress(InetAddress.getByName(host), port)), "statsd-metrics-sender") + 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") @@ -55,4 +54,3 @@ class StatsdMetricsListener(host:String, port:Int, prefix:String) extends Actor } } - |