aboutsummaryrefslogtreecommitdiff
path: root/kamon-newrelic/src/main/scala
diff options
context:
space:
mode:
authorIvan Topolnjak <ivantopo@gmail.com>2015-02-15 01:47:32 +0100
committerIvan Topolnjak <ivantopo@gmail.com>2015-02-15 01:47:32 +0100
commit81c52c27d2b4784d561ae63b884b6e8c9e03db58 (patch)
tree1414f438c83976d60e98d27041ec3c177094881e /kamon-newrelic/src/main/scala
parenta313e1e94b1f8a660e24a47f7f76a28a97dad8ff (diff)
downloadKamon-81c52c27d2b4784d561ae63b884b6e8c9e03db58.tar.gz
Kamon-81c52c27d2b4784d561ae63b884b6e8c9e03db58.tar.bz2
Kamon-81c52c27d2b4784d561ae63b884b6e8c9e03db58.zip
= all: stop using config.getDuration in favor of config.getFiniteDuration.
Diffstat (limited to 'kamon-newrelic/src/main/scala')
-rw-r--r--kamon-newrelic/src/main/scala/kamon/newrelic/Agent.scala12
-rw-r--r--kamon-newrelic/src/main/scala/kamon/newrelic/MetricReporter.scala6
2 files changed, 8 insertions, 10 deletions
diff --git a/kamon-newrelic/src/main/scala/kamon/newrelic/Agent.scala b/kamon-newrelic/src/main/scala/kamon/newrelic/Agent.scala
index aa6aed3b..e65b2460 100644
--- a/kamon-newrelic/src/main/scala/kamon/newrelic/Agent.scala
+++ b/kamon-newrelic/src/main/scala/kamon/newrelic/Agent.scala
@@ -16,8 +16,6 @@
package kamon.newrelic
-import java.util.concurrent.TimeUnit.{ MILLISECONDS ⇒ milliseconds }
-
import akka.actor.{ ActorLogging, Actor }
import akka.io.IO
import akka.util.Timeout
@@ -28,11 +26,13 @@ import scala.concurrent.Future
import spray.httpx.SprayJsonSupport
import spray.json.lenses.JsonLenses._
import java.lang.management.ManagementFactory
-import scala.concurrent.duration._
+import kamon.util.ConfigTools.Syntax
import Agent._
import JsonProtocol._
import akka.pattern.pipe
+import scala.concurrent.duration.FiniteDuration
+
class Agent extends Actor with SprayJsonSupport with ActorLogging {
import context.dispatcher
@@ -136,9 +136,9 @@ object AgentSettings {
newRelicConfig.getString("app-name"),
runtimeName(1),
runtimeName(0).toInt,
- Timeout(newRelicConfig.getDuration("operation-timeout", milliseconds).millis),
+ Timeout(newRelicConfig.getFiniteDuration("operation-timeout")),
newRelicConfig.getInt("max-connect-retries"),
- FiniteDuration(newRelicConfig.getDuration("connect-retry-delay", milliseconds), milliseconds),
- newRelicConfig.getDuration("apdexT", milliseconds) / 1E3D)
+ newRelicConfig.getFiniteDuration("connect-retry-delay"),
+ newRelicConfig.getFiniteDuration("apdexT").toMillis / 1E3D)
}
} \ No newline at end of file
diff --git a/kamon-newrelic/src/main/scala/kamon/newrelic/MetricReporter.scala b/kamon-newrelic/src/main/scala/kamon/newrelic/MetricReporter.scala
index 31c04f7a..7ee7d1e6 100644
--- a/kamon-newrelic/src/main/scala/kamon/newrelic/MetricReporter.scala
+++ b/kamon-newrelic/src/main/scala/kamon/newrelic/MetricReporter.scala
@@ -1,7 +1,5 @@
package kamon.newrelic
-import java.util.concurrent.TimeUnit
-
import akka.actor.{ Props, ActorLogging, Actor }
import akka.pattern.pipe
import akka.io.IO
@@ -22,10 +20,10 @@ class MetricReporter(settings: AgentSettings) extends Actor with ActorLogging wi
val metricsExtension = Kamon.metrics
val collectionContext = metricsExtension.buildDefaultCollectionContext
val metricsSubscriber = {
- val tickInterval = context.system.settings.config.getDuration("kamon.metric.tick-interval", TimeUnit.MILLISECONDS)
+ val tickInterval = Kamon.metrics.settings.tickInterval
// Metrics are always sent to New Relic in 60 seconds intervals.
- if (tickInterval == 60000) self
+ if (tickInterval == 60.seconds) self
else context.actorOf(TickMetricSnapshotBuffer.props(1 minute, self), "metric-buffer")
}