diff options
| author | Ivan Topolnak <ivantopo@gmail.com> | 2013-05-15 18:47:22 -0300 |
|---|---|---|
| committer | Ivan Topolnak <ivantopo@gmail.com> | 2013-05-15 18:47:22 -0300 |
| commit | 83e51763db4da386fb22b670aab9b0c2beda20d2 (patch) | |
| tree | b6bd0f1a63fd02e75208e6a6cec21dc1724b9b55 /src/main/scala/akka/Tracer.scala | |
| parent | ee1b12e22a502308a26208f87132f08d356d1e1e (diff) | |
| download | Kamon-83e51763db4da386fb22b670aab9b0c2beda20d2.tar.gz Kamon-83e51763db4da386fb22b670aab9b0c2beda20d2.tar.bz2 Kamon-83e51763db4da386fb22b670aab9b0c2beda20d2.zip | |
wip
Diffstat (limited to 'src/main/scala/akka/Tracer.scala')
| -rw-r--r-- | src/main/scala/akka/Tracer.scala | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/main/scala/akka/Tracer.scala b/src/main/scala/akka/Tracer.scala index bb290960..c58983e0 100644 --- a/src/main/scala/akka/Tracer.scala +++ b/src/main/scala/akka/Tracer.scala @@ -3,6 +3,7 @@ package akka import actor.{Props, ActorSystemImpl} import scala.concurrent.forkjoin.ForkJoinPool import scala.concurrent.duration._ +import com.newrelic.api.agent.NewRelic import akka.dispatch.Mailbox import scala._ import com.newrelic.api.agent.NewRelic @@ -28,6 +29,7 @@ object Tracer { val mbm = MailboxMetrics(mailboxes) mbm.mailboxes.map { case(actorName,mb) => { println(s"Sending metrics to Newrelic MailBoxMonitor -> ${actorName}") + NewRelic.recordMetric(s"${actorName}:Mailbox:NumberOfMessages",mb.numberOfMessages) NewRelic.recordMetric(s"${actorName}:Mailbox:MailboxDispatcherThroughput",mb.dispatcher.throughput) |