+ datadog: subscribe and report user metrics

1 files changed, 8 insertions, 0 deletions

diff --git a/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala b/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala
index 6498f851..65b4cd37 100644
--- a/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala
+++ b/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala
@@ -22,6 +22,7 @@ import java.util.concurrent.TimeUnit.MILLISECONDS
 import akka.actor._
 import akka.event.Logging
 import kamon.Kamon
+import kamon.metric.UserMetrics.{UserGauges, UserMinMaxCounters, UserCounters, UserHistograms}
 import kamon.metric._
 import kamon.metrics._
 
@@ -50,6 +51,13 @@ class DatadogExtension(system: ExtendedActorSystem) extends Kamon.Extension {
 
   val datadogMetricsListener = buildMetricsListener(tickInterval, flushInterval)
 
+
+  // Subscribe to all user metrics
+  Kamon(Metrics)(system).subscribe(UserHistograms, "*", datadogMetricsListener, permanently = true)
+  Kamon(Metrics)(system).subscribe(UserCounters, "*", datadogMetricsListener, permanently = true)
+  Kamon(Metrics)(system).subscribe(UserMinMaxCounters, "*", datadogMetricsListener, permanently = true)
+  Kamon(Metrics)(system).subscribe(UserGauges, "*", datadogMetricsListener, permanently = true)
+
   // Subscribe to Actors
   val includedActors = datadogConfig.getStringList("includes.actor").asScala
   for (actorPathPattern ← includedActors) {