diff options
author | Ivan Topolnak <ivantopo@gmail.com> | 2013-09-10 18:35:25 -0300 |
---|---|---|
committer | Ivan Topolnak <ivantopo@gmail.com> | 2013-09-10 18:35:25 -0300 |
commit | d8305b781aaf454cec558bfb86a366682e9f5eab (patch) | |
tree | d2ae762332faef33aedfaf68b1732611c4f1542d /kamon-core/src/main/scala/kamon/Kamon.scala | |
parent | 218b8896f2987c43068646cea8eca597ceaf0843 (diff) | |
download | Kamon-d8305b781aaf454cec558bfb86a366682e9f5eab.tar.gz Kamon-d8305b781aaf454cec558bfb86a366682e9f5eab.tar.bz2 Kamon-d8305b781aaf454cec558bfb86a366682e9f5eab.zip |
Simple instrumentation just for keeping the uow.
Diffstat (limited to 'kamon-core/src/main/scala/kamon/Kamon.scala')
-rw-r--r-- | kamon-core/src/main/scala/kamon/Kamon.scala | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/kamon-core/src/main/scala/kamon/Kamon.scala b/kamon-core/src/main/scala/kamon/Kamon.scala index 298f43eb..118239f7 100644 --- a/kamon-core/src/main/scala/kamon/Kamon.scala +++ b/kamon-core/src/main/scala/kamon/Kamon.scala @@ -5,6 +5,12 @@ import kamon.metric.{HistogramSnapshot, ActorSystemMetrics} import scala.concurrent.duration.FiniteDuration import com.newrelic.api.agent.NewRelic import scala.collection.concurrent.TrieMap +import kamon.instrumentation.{SimpleContextPassingInstrumentation, ActorInstrumentationConfiguration} + + +object Instrument { + val instrumentation: ActorInstrumentationConfiguration = new SimpleContextPassingInstrumentation +} object Kamon { implicit lazy val actorSystem = ActorSystem("kamon") @@ -19,8 +25,8 @@ object Kamon { def actorSystem(name: String): Option[ActorSystemMetrics] = actorSystems.get(name) } - val metricManager = actorSystem.actorOf(Props[MetricManager], "metric-manager") - val newrelicReporter = actorSystem.actorOf(Props[NewrelicReporterActor], "newrelic-reporter") + //val metricManager = actorSystem.actorOf(Props[MetricManager], "metric-manager") + //val newrelicReporter = actorSystem.actorOf(Props[NewrelicReporterActor], "newrelic-reporter") } @@ -79,7 +85,7 @@ case class DispatcherMetrics(actorSystem: String, dispatcher: String, activeThre class NewrelicReporterActor extends Actor { import scala.concurrent.duration._ - Kamon.metricManager ! RegisterForAllDispatchers(5 seconds) + //Kamon.metricManager ! RegisterForAllDispatchers(5 seconds) def receive = { case DispatcherMetrics(actorSystem, dispatcher, activeThreads, poolSize, queueSize) => { |