Add try-catch to VersionFiltering (#939)

kamon-io · Feb 10, 2021 · 82a6fe3 · 82a6fe3
1 parent bc067bf
commit 82a6fe3
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/...ion/kamon-akka-http/src/main/scala/kamon/instrumentation/akka/http/VersionFiltering.scala b/...ion/kamon-akka-http/src/main/scala/kamon/instrumentation/akka/http/VersionFiltering.scala
@@ -2,7 +2,17 @@ package kamon.instrumentation.akka.http
 
 trait VersionFiltering {
   def onAkkaHttp(version: String)(block: => Unit): Unit = {
-    if(akka.http.Version.current.startsWith(version))
+    val akkaHttpVersion = getVersion
+
+    if (akkaHttpVersion.exists(_.startsWith(version)))
       block
   }
+
+  private def getVersion: Option[String] = {
+    try {
+      Option(akka.http.Version.current)
+    } catch {
+      case _: Throwable => None
+    }
+  }
 }