aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/kamon/Kamon.scala
diff options
context:
space:
mode:
authorIvan Topolnak <ivantopo@gmail.com>2013-09-10 18:35:25 -0300
committerIvan Topolnak <ivantopo@gmail.com>2013-09-10 18:35:25 -0300
commitd8305b781aaf454cec558bfb86a366682e9f5eab (patch)
treed2ae762332faef33aedfaf68b1732611c4f1542d /kamon-core/src/main/scala/kamon/Kamon.scala
parent218b8896f2987c43068646cea8eca597ceaf0843 (diff)
downloadKamon-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.scala12
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) => {