diff options
author | Ivan Topolnjak <ivantopo@gmail.com> | 2014-07-28 01:02:02 -0300 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2014-07-28 01:02:02 -0300 |
commit | 97d299613bd725540e5279708ecfcade59dcda70 (patch) | |
tree | 52e8cab8dffb8104c4c711b8afed73c9d4c8ffb5 /kamon-core/src/main/scala/kamon/metric/MetricsExtension.scala | |
parent | 90202659d0385da0797af516471808751f05c935 (diff) | |
download | Kamon-97d299613bd725540e5279708ecfcade59dcda70.tar.gz Kamon-97d299613bd725540e5279708ecfcade59dcda70.tar.bz2 Kamon-97d299613bd725540e5279708ecfcade59dcda70.zip |
= core: subscription protocol specification, closes #51
Diffstat (limited to 'kamon-core/src/main/scala/kamon/metric/MetricsExtension.scala')
-rw-r--r-- | kamon-core/src/main/scala/kamon/metric/MetricsExtension.scala | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/kamon-core/src/main/scala/kamon/metric/MetricsExtension.scala b/kamon-core/src/main/scala/kamon/metric/MetricsExtension.scala index abc6e44e..00214f51 100644 --- a/kamon-core/src/main/scala/kamon/metric/MetricsExtension.scala +++ b/kamon-core/src/main/scala/kamon/metric/MetricsExtension.scala @@ -26,7 +26,7 @@ import kamon.util.GlobPathFilter import kamon.Kamon import akka.actor import kamon.metric.Metrics.MetricGroupFilter -import kamon.metric.Subscriptions.Subscribe +import kamon.metric.Subscriptions.{ Unsubscribe, Subscribe } import java.util.concurrent.TimeUnit class MetricsExtension(system: ExtendedActorSystem) extends Kamon.Extension { @@ -55,9 +55,11 @@ class MetricsExtension(system: ExtendedActorSystem) extends Kamon.Extension { storage.remove(identity) } - def subscribe[C <: MetricGroupCategory](category: C, selection: String, receiver: ActorRef, permanently: Boolean = false): Unit = { - subscriptions.tell(Subscribe(category, selection, permanently), receiver) - } + def subscribe[C <: MetricGroupCategory](category: C, selection: String, subscriber: ActorRef, permanently: Boolean = false): Unit = + subscriptions.tell(Subscribe(category, selection, subscriber, permanently), subscriber) + + def unsubscribe(subscriber: ActorRef): Unit = + subscriptions.tell(Unsubscribe(subscriber), subscriber) def scheduleGaugeRecorder(body: ⇒ Unit): Cancellable = { import scala.concurrent.duration._ |