diff options
author | Ivan Topolnak <itopolnak@despegar.com> | 2014-01-30 18:23:33 -0300 |
---|---|---|
committer | Ivan Topolnak <itopolnak@despegar.com> | 2014-01-30 18:23:33 -0300 |
commit | a15e17d2462105ad8b72054be58dc9e8f9dc64ed (patch) | |
tree | 9e8c3d1fa732918dc600538bab24940bd18b6e79 /kamon-core/src/main/scala/kamon/metrics/MetricsExtension.scala | |
parent | e47ed388f6ae147e550c39aa2a3638791ec65b66 (diff) | |
download | Kamon-a15e17d2462105ad8b72054be58dc9e8f9dc64ed.tar.gz Kamon-a15e17d2462105ad8b72054be58dc9e8f9dc64ed.tar.bz2 Kamon-a15e17d2462105ad8b72054be58dc9e8f9dc64ed.zip |
wip
Diffstat (limited to 'kamon-core/src/main/scala/kamon/metrics/MetricsExtension.scala')
-rw-r--r-- | kamon-core/src/main/scala/kamon/metrics/MetricsExtension.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/kamon-core/src/main/scala/kamon/metrics/MetricsExtension.scala b/kamon-core/src/main/scala/kamon/metrics/MetricsExtension.scala index 4d7ff354..a717e25a 100644 --- a/kamon-core/src/main/scala/kamon/metrics/MetricsExtension.scala +++ b/kamon-core/src/main/scala/kamon/metrics/MetricsExtension.scala @@ -33,9 +33,9 @@ class MetricsExtension(val system: ExtendedActorSystem) extends Kamon.Extension val filters = loadFilters(config) lazy val subscriptions = system.actorOf(Props[Subscriptions], "kamon-metrics-subscriptions") - def register(name: String, category: MetricGroupIdentity.Category with MetricGroupFactory): Option[category.Group] = { + def register(name: String, category: MetricGroupIdentity.Category with MetricGroupFactory): Option[category.GroupRecorder] = { if (shouldTrack(name, category)) - Some(storage.getOrElseUpdate(MetricGroupIdentity(name, category), category.create(config)).asInstanceOf[category.Group]) + Some(storage.getOrElseUpdate(MetricGroupIdentity(name, category), category.create(config)).asInstanceOf[category.GroupRecorder]) else None } @@ -53,7 +53,7 @@ class MetricsExtension(val system: ExtendedActorSystem) extends Kamon.Extension } private def shouldTrack(name: String, category: MetricGroupIdentity.Category): Boolean = { - filters.get(category.name).map(filter ⇒ filter.accept(name)).getOrElse(false) + filters.get(category.entityName).map(filter ⇒ filter.accept(name)).getOrElse(false) } def loadFilters(config: Config): Map[String, MetricGroupFilter] = { |