From c6bb65535bcc3cc1ff3834a91473ee8dfa6145e8 Mon Sep 17 00:00:00 2001 From: Ivan Topolnjak Date: Thu, 12 Feb 2015 11:30:06 +0100 Subject: ! all: Kamon now works as a single instance in a companion object. --- .../src/main/scala/kamon/datadog/Datadog.scala | 2 +- .../kamon/datadog/DatadogMetricSenderSpec.scala | 34 +++++++++++----------- 2 files changed, 18 insertions(+), 18 deletions(-) (limited to 'kamon-datadog/src') diff --git a/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala b/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala index b7375d9b..53ffd4e6 100644 --- a/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala +++ b/kamon-datadog/src/main/scala/kamon/datadog/Datadog.scala @@ -50,7 +50,7 @@ class DatadogExtension(system: ExtendedActorSystem) extends Kamon.Extension { val subscriptions = datadogConfig.getConfig("subscriptions") subscriptions.firstLevelKeys.map { subscriptionCategory ⇒ subscriptions.getStringList(subscriptionCategory).asScala.foreach { pattern ⇒ - Kamon(Metrics).subscribe(subscriptionCategory, pattern, datadogMetricsListener, permanently = true) + Kamon.metrics.subscribe(subscriptionCategory, pattern, datadogMetricsListener, permanently = true) } } diff --git a/kamon-datadog/src/test/scala/kamon/datadog/DatadogMetricSenderSpec.scala b/kamon-datadog/src/test/scala/kamon/datadog/DatadogMetricSenderSpec.scala index 1fcc0c5d..b35902f9 100644 --- a/kamon-datadog/src/test/scala/kamon/datadog/DatadogMetricSenderSpec.scala +++ b/kamon-datadog/src/test/scala/kamon/datadog/DatadogMetricSenderSpec.scala @@ -20,6 +20,7 @@ import akka.testkit.{ TestKitBase, TestProbe } import akka.actor.{ Props, ActorRef, ActorSystem } import kamon.Kamon import kamon.metric.instrument._ +import kamon.testkit.BaseKamonSpec import kamon.util.MilliTimestamp import org.scalatest.{ Matchers, WordSpecLike } import kamon.metric._ @@ -29,22 +30,21 @@ import java.lang.management.ManagementFactory import java.net.InetSocketAddress import com.typesafe.config.ConfigFactory -class DatadogMetricSenderSpec extends TestKitBase with WordSpecLike with Matchers { - implicit lazy val system: ActorSystem = ActorSystem("datadog-metric-sender-spec", ConfigFactory.parseString( - """ - |kamon { - | metrics { - | disable-aspectj-weaver-missing-error = true - | } - | - | datadog { - | max-packet-size = 256 bytes - | } - |} - | - """.stripMargin)) - - val collectionContext = Kamon(Metrics).buildDefaultCollectionContext +class DatadogMetricSenderSpec extends BaseKamonSpec("datadog-metric-sender-spec") { + override lazy val config = + ConfigFactory.parseString( + """ + |kamon { + | metrics { + | disable-aspectj-weaver-missing-error = true + | } + | + | datadog { + | max-packet-size = 256 bytes + | } + |} + | + """.stripMargin) "the DataDogMetricSender" should { "send latency measurements" in new UdpListenerFixture { @@ -106,7 +106,7 @@ class DatadogMetricSenderSpec extends TestKitBase with WordSpecLike with Matcher val testMaxPacketSize = system.settings.config.getBytes("kamon.datadog.max-packet-size") def buildRecorder(name: String): (Entity, TestEntityRecorder) = { - val registration = Kamon(Metrics).register(TestEntityRecorder, name).get + val registration = Kamon.metrics.register(TestEntityRecorder, name).get (registration.entity, registration.recorder) } -- cgit v1.2.3