aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorDiego <diegolparra@gmail.com>2014-04-02 19:56:43 -0300
committerDiego <diegolparra@gmail.com>2014-04-02 20:12:40 -0300
commitdd59c81129d729887e5481a843dbbcabf6bf08b8 (patch)
tree74fce1235872b383790fad39623507006cd2c5c3
parent94598b69c20b18ec43a1479a924295030b47c2f4 (diff)
downloadKamon-dd59c81129d729887e5481a843dbbcabf6bf08b8.tar.gz
Kamon-dd59c81129d729887e5481a843dbbcabf6bf08b8.tar.bz2
Kamon-dd59c81129d729887e5481a843dbbcabf6bf08b8.zip
added actorMetrics
-rw-r--r--kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala4
1 files changed, 3 insertions, 1 deletions
diff --git a/kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala b/kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala
index c4212092..124cdab8 100644
--- a/kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala
+++ b/kamon-statsd/src/main/scala/kamon/statsd/Statsd.scala
@@ -19,8 +19,9 @@ package kamon.statsd
import akka.actor._
import kamon.Kamon
import kamon.metrics.Subscriptions.TickMetricSnapshot
-import kamon.metrics.{ TickMetricSnapshotBuffer, CustomMetric, TraceMetrics, Metrics }
+import kamon.metrics._
import scala.concurrent.duration._
+import kamon.metrics.Subscriptions.TickMetricSnapshot
object Statsd extends ExtensionId[StatsdExtension] with ExtensionIdProvider {
override def lookup(): ExtensionId[_ <: Extension] = Statsd
@@ -39,6 +40,7 @@ class StatsdExtension(private val system: ExtendedActorSystem) extends Kamon.Ext
Kamon(Metrics)(system).subscribe(TraceMetrics, "*", statsdMetricsListener, permanently = true)
Kamon(Metrics)(system).subscribe(CustomMetric, "*", statsdMetricsListener, permanently = true)
+ Kamon(Metrics)(system).subscribe(ActorMetrics, "*", statsdMetricsListener, permanently = true)
}
class StatsdMetricsListener(host: String, port: Int, prefix: String) extends Actor with ActorLogging {