diff options
Diffstat (limited to 'kamon-jdbc/src/test/scala/kamon/jdbc/instrumentation/StatementInstrumentationSpec.scala')
-rw-r--r-- | kamon-jdbc/src/test/scala/kamon/jdbc/instrumentation/StatementInstrumentationSpec.scala | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/kamon-jdbc/src/test/scala/kamon/jdbc/instrumentation/StatementInstrumentationSpec.scala b/kamon-jdbc/src/test/scala/kamon/jdbc/instrumentation/StatementInstrumentationSpec.scala index ffd5a867..4b400727 100644 --- a/kamon-jdbc/src/test/scala/kamon/jdbc/instrumentation/StatementInstrumentationSpec.scala +++ b/kamon-jdbc/src/test/scala/kamon/jdbc/instrumentation/StatementInstrumentationSpec.scala @@ -21,7 +21,7 @@ import akka.actor.ActorSystem import akka.testkit.{ TestKitBase, TestProbe } import com.typesafe.config.ConfigFactory import kamon.Kamon -import kamon.jdbc.SlowQueryProcessor +import kamon.jdbc.{ SqlErrorProcessor, SlowQueryProcessor } import kamon.jdbc.metric.StatementsMetrics import kamon.jdbc.metric.StatementsMetrics.StatementsMetricsSnapshot import kamon.metric.Metrics @@ -41,6 +41,9 @@ class StatementInstrumentationSpec extends TestKitBase with WordSpecLike with Ma | | # Fully qualified name of the implementation of kamon.jdbc.SlowQueryProcessor. | slow-query-processor = kamon.jdbc.instrumentation.NOPSlowQueryProcessor + | + | # Fully qualified name of the implementation of kamon.jdbc.SqlErrorProcessor. + | sql-error-processor = kamon.jdbc.instrumentation.NOPSqlErrorProcessor | } |} """.stripMargin)) @@ -182,3 +185,7 @@ class NOPSlowQueryProcessor extends SlowQueryProcessor { override def process(sql: String, executionTimeInMillis: Long, queryThresholdInMillis: Long): Unit = { /*do nothing!!!*/ } } +class NOPSqlErrorProcessor extends SqlErrorProcessor { + override def process(sql: String, ex: Throwable): Unit = { /*do nothing!!!*/ } +} + |