aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/kamon/metric/NewRelicReporter.scala
diff options
context:
space:
mode:
authorDiego Parra <diegolparra@gmail.com>2013-05-05 20:33:28 -0300
committerDiego Parra <diegolparra@gmail.com>2013-05-05 20:33:28 -0300
commit2f81f03742860a0a57cebeea6f0160f3c0d80a48 (patch)
tree2715ea8499f8245d31976ff2450c47da3cf64f4c /src/main/scala/kamon/metric/NewRelicReporter.scala
parent2caece9ef7574406c548b4a1f333de4c9579b3a2 (diff)
downloadKamon-2f81f03742860a0a57cebeea6f0160f3c0d80a48.tar.gz
Kamon-2f81f03742860a0a57cebeea6f0160f3c0d80a48.tar.bz2
Kamon-2f81f03742860a0a57cebeea6f0160f3c0d80a48.zip
added Mailbox, PoolMonitor and ActorSystem Aspects and fix newRelicReporter
Diffstat (limited to 'src/main/scala/kamon/metric/NewRelicReporter.scala')
-rw-r--r--src/main/scala/kamon/metric/NewRelicReporter.scala12
1 files changed, 2 insertions, 10 deletions
diff --git a/src/main/scala/kamon/metric/NewRelicReporter.scala b/src/main/scala/kamon/metric/NewRelicReporter.scala
index 9aa374aa..fa6b29f3 100644
--- a/src/main/scala/kamon/metric/NewRelicReporter.scala
+++ b/src/main/scala/kamon/metric/NewRelicReporter.scala
@@ -3,12 +3,11 @@ package kamon.metric
import com.newrelic.api.agent.NewRelic
import com.yammer.metrics.reporting.AbstractPollingReporter
import com.yammer.metrics.core._
+import scala.collection.JavaConversions._
class NewRelicReporter(registry: MetricsRegistry, name: String) extends AbstractPollingReporter(registry, name) with MetricProcessor[String] {
-
-
def processMeter(name: MetricName, meter: Metered, context: String) {
println(s"Logging to NewRelic: ${meter.count()}")
NewRelic.recordMetric("Custom/Actor/MessagesPerSecond", meter.count())
@@ -23,19 +22,12 @@ class NewRelicReporter(registry: MetricsRegistry, name: String) extends Abstract
def processGauge(name: MetricName, gauge: Gauge[_], context: String) {}
- private final val predicate: MetricPredicate = null
-
def run() {
- import scala.collection.JavaConversions._
- for (entry <- getMetricsRegistry.groupedMetrics(predicate).entrySet) {
- import scala.collection.JavaConversions._
+ for (entry <- getMetricsRegistry.groupedMetrics(MetricPredicate.ALL).entrySet) {
for (subEntry <- entry.getValue.entrySet) {
subEntry.getValue.processWith(this, subEntry.getKey, "")
}
-
}
-
}
-
}