path: root/src/main/scala/kamon/metric/NewRelicReporter.scala

package kamon.metric

import com.newrelic.api.agent.NewRelic
import com.yammer.metrics.reporting.AbstractPollingReporter
import com.yammer.metrics.core._


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())
  }


  def processCounter(name: MetricName, counter: Counter, context: String) {}

  def processHistogram(name: MetricName, histogram: Histogram, context: String) {}

  def processTimer(name: MetricName, timer: Timer, context: String) {}

  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 (subEntry <- entry.getValue.entrySet) {
        subEntry.getValue.processWith(this, subEntry.getKey, "")
      }

    }

  }

}