From 81c52c27d2b4784d561ae63b884b6e8c9e03db58 Mon Sep 17 00:00:00 2001 From: Ivan Topolnjak Date: Sun, 15 Feb 2015 01:47:32 +0100 Subject: = all: stop using config.getDuration in favor of config.getFiniteDuration. --- kamon-jdbc/src/main/scala/kamon/jdbc/Jdbc.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'kamon-jdbc') diff --git a/kamon-jdbc/src/main/scala/kamon/jdbc/Jdbc.scala b/kamon-jdbc/src/main/scala/kamon/jdbc/Jdbc.scala index 036789b7..f66af7a6 100644 --- a/kamon-jdbc/src/main/scala/kamon/jdbc/Jdbc.scala +++ b/kamon-jdbc/src/main/scala/kamon/jdbc/Jdbc.scala @@ -15,7 +15,7 @@ package kamon.jdbc -import java.util.concurrent.TimeUnit.{ MILLISECONDS ⇒ milliseconds } +import kamon.util.ConfigTools.Syntax import akka.actor.{ ExtendedActorSystem, Extension, ExtensionId, ExtensionIdProvider } import kamon.Kamon @@ -39,7 +39,7 @@ class JdbcExtension(system: ExtendedActorSystem) extends Kamon.Extension { private val sqlErrorProcessorClass = config.getString("sql-error-processor") private val sqlErrorProcessor: SqlErrorProcessor = system.dynamicAccess.createInstanceFor[SqlErrorProcessor](sqlErrorProcessorClass, Nil).get - val slowQueryThreshold = config.getDuration("slow-query-threshold", milliseconds) + val slowQueryThreshold = config.getFiniteDuration("slow-query-threshold").toMillis def processSlowQuery(sql: String, executionTime: Long) = slowQueryProcessor.process(sql, executionTime, slowQueryThreshold) def processSqlError(sql: String, ex: Throwable) = sqlErrorProcessor.process(sql, ex) -- cgit v1.2.3