+ statsd: report HttpServerMetrics to StatsD

2 files changed, 6 insertions, 2 deletions

diff --git a/kamon-core/src/main/resources/reference.conf b/kamon-core/src/main/resources/reference.conf
index da09f500..2d8b3f2e 100644
--- a/kamon-core/src/main/resources/reference.conf
+++ b/kamon-core/src/main/resources/reference.conf
@@ -172,7 +172,7 @@ kamon {
       max-incubation-time = 20 seconds
     }
 
-    # Default dispatcher for all trace operations
+    # Default dispatcher for all trace module operations
     dispatcher = ${kamon.default-dispatcher}
   }
 
@@ -185,7 +185,7 @@ kamon {
     #   - heavyweight: logs the warning when a timeout is reached using a stack trace captured at the moment the future was created.
     ask-pattern-timeout-warning = off
 
-    # Default dispatcher for all trace operations
+    # Default dispatcher for all akka module operations
     dispatcher = ${kamon.default-dispatcher}
   }
 
diff --git a/kamon-statsd/src/main/scala/kamon/statsd/StatsD.scala b/kamon-statsd/src/main/scala/kamon/statsd/StatsD.scala
index a465de52..f3f7761d 100644
--- a/kamon-statsd/src/main/scala/kamon/statsd/StatsD.scala
+++ b/kamon-statsd/src/main/scala/kamon/statsd/StatsD.scala
@@ -18,6 +18,7 @@ package kamon.statsd
 
 import akka.actor._
 import kamon.Kamon
+import kamon.http.HttpServerMetrics
 import kamon.metric.UserMetrics._
 import kamon.metric._
 import kamon.metrics._
@@ -54,6 +55,9 @@ class StatsDExtension(system: ExtendedActorSystem) extends Kamon.Extension {
   Kamon(Metrics)(system).subscribe(UserMinMaxCounters, "*", statsDMetricsListener, permanently = true)
   Kamon(Metrics)(system).subscribe(UserGauges, "*", statsDMetricsListener, permanently = true)
 
+  // Subscribe to server metrics
+  Kamon(Metrics)(system).subscribe(HttpServerMetrics.category, "*", statsDMetricsListener, permanently = true)
+
   // Subscribe to Actors
   val includedActors = statsDConfig.getStringList("includes.actor").asScala
   for (actorPathPattern ← includedActors) {