aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/metric/SubscriptionsDispatcher.scala
diff options
context:
space:
mode:
authorIvan Topolnjak <ivantopo@gmail.com>2015-02-15 10:46:36 +0100
committerIvan Topolnjak <ivantopo@gmail.com>2015-02-15 10:46:36 +0100
commit8a532fc8c95a5700721248b6b4f558d9a1dcebcb (patch)
tree8f7f299e717ec6044b2eaa1f0922b0cbae02fd90 /kamon-core/src/main/scala/kamon/metric/SubscriptionsDispatcher.scala
parent0688c1a84caba17a600c498b158013f9867e4093 (diff)
downloadKamon-8a532fc8c95a5700721248b6b4f558d9a1dcebcb.tar.gz
Kamon-8a532fc8c95a5700721248b6b4f558d9a1dcebcb.tar.bz2
Kamon-8a532fc8c95a5700721248b6b4f558d9a1dcebcb.zip
! core: drop the Extension postfix on all core components.
Diffstat (limited to 'kamon-core/src/main/scala/kamon/metric/SubscriptionsDispatcher.scala')
-rw-r--r--kamon-core/src/main/scala/kamon/metric/SubscriptionsDispatcher.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/kamon-core/src/main/scala/kamon/metric/SubscriptionsDispatcher.scala b/kamon-core/src/main/scala/kamon/metric/SubscriptionsDispatcher.scala
index 68b545a5..3b6be70b 100644
--- a/kamon-core/src/main/scala/kamon/metric/SubscriptionsDispatcher.scala
+++ b/kamon-core/src/main/scala/kamon/metric/SubscriptionsDispatcher.scala
@@ -24,7 +24,7 @@ import scala.concurrent.duration.FiniteDuration
/**
* Manages subscriptions to metrics and dispatch snapshots on every tick to all subscribers.
*/
-private[kamon] class SubscriptionsDispatcher(interval: FiniteDuration, metricsExtension: MetricsExtensionImpl) extends Actor {
+private[kamon] class SubscriptionsDispatcher(interval: FiniteDuration, metricsExtension: MetricsImpl) extends Actor {
var lastTick = MilliTimestamp.now
var oneShotSubscriptions = Map.empty[ActorRef, SubscriptionFilter]
var permanentSubscriptions = Map.empty[ActorRef, SubscriptionFilter]
@@ -81,7 +81,7 @@ private[kamon] class SubscriptionsDispatcher(interval: FiniteDuration, metricsEx
}
object SubscriptionsDispatcher {
- def props(interval: FiniteDuration, metricsExtension: MetricsExtensionImpl): Props =
+ def props(interval: FiniteDuration, metricsExtension: MetricsImpl): Props =
Props(new SubscriptionsDispatcher(interval, metricsExtension))
case object Tick