aboutsummaryrefslogtreecommitdiff
path: root/kamon-jdbc/src/test/scala/kamon/jdbc/instrumentation/StatementInstrumentationSpec.scala
diff options
context:
space:
mode:
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.scala9
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!!!*/ }
+}
+