Skip to content

Commit 1c6d97b

Browse files
authored
Fix Akka's and Pekko's filters.actors.doomsday-wildcard (#1403)
1 parent 8f45f7b commit 1c6d97b

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

instrumentation/kamon-akka/src/common/scala/kamon/instrumentation/akka/AkkaInstrumentation.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ object AkkaInstrumentation {
115115
private def safeFilter(config: Config, allowDoomsday: Boolean): Filter = {
116116
val includes = config.getStringList("includes").asScala
117117
if(!allowDoomsday && includes.contains("**")) {
118-
val newIncludes = "includes = " + includes.filter(_ == "**").map(s => s""""$s"""").mkString("[ ", ", ", " ]")
118+
val newIncludes = "includes = " + includes.filterNot(_ == "**").map(s => s""""$s"""").mkString("[ ", ", ", " ]")
119119
val safeFilterConfig = ConfigFactory.parseString(newIncludes).withFallback(config)
120120

121121
Filter.from(safeFilterConfig)

instrumentation/kamon-pekko/src/main/scala/kamon/instrumentation/pekko/PekkoInstrumentation.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ object PekkoInstrumentation {
115115
private def safeFilter(config: Config, allowDoomsday: Boolean): Filter = {
116116
val includes = config.getStringList("includes").asScala
117117
if (!allowDoomsday && includes.contains("**")) {
118-
val newIncludes = "includes = " + includes.filter(_ == "**").map(s => s""""$s"""").mkString("[ ", ", ", " ]")
118+
val newIncludes = "includes = " + includes.filterNot(_ == "**").map(s => s""""$s"""").mkString("[ ", ", ", " ]")
119119
val safeFilterConfig = ConfigFactory.parseString(newIncludes).withFallback(config)
120120

121121
Filter.from(safeFilterConfig)

0 commit comments

Comments
 (0)