From 47f2088a6e14963af7111fb214d35e001a5f11ca Mon Sep 17 00:00:00 2001 From: Chris Larsen Date: Wed, 5 Apr 2023 12:17:47 -0700 Subject: [PATCH] atlas cloudwatch: Fix tagging of routing queue metric. --- .../main/scala/com/netflix/atlas/cloudwatch/PublishRouter.scala | 2 +- .../scala/com/netflix/atlas/cloudwatch/PublishRouterSuite.scala | 2 -- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/atlas-cloudwatch/src/main/scala/com/netflix/atlas/cloudwatch/PublishRouter.scala b/atlas-cloudwatch/src/main/scala/com/netflix/atlas/cloudwatch/PublishRouter.scala index 2db1c355..de19c10f 100644 --- a/atlas-cloudwatch/src/main/scala/com/netflix/atlas/cloudwatch/PublishRouter.scala +++ b/atlas-cloudwatch/src/main/scala/com/netflix/atlas/cloudwatch/PublishRouter.scala @@ -81,7 +81,7 @@ class PublishRouter( r.getKey -> new PublishQueue( config.getConfig("atlas.cloudwatch.account.routing"), registry, - destination, + stack + "-" + destination, baseURI .replaceAll("\\$\\{STACK\\}", stack) .replaceAll("\\$\\{REGION}", destination), diff --git a/atlas-cloudwatch/src/test/scala/com/netflix/atlas/cloudwatch/PublishRouterSuite.scala b/atlas-cloudwatch/src/test/scala/com/netflix/atlas/cloudwatch/PublishRouterSuite.scala index 93e89695..dc3ee672 100644 --- a/atlas-cloudwatch/src/test/scala/com/netflix/atlas/cloudwatch/PublishRouterSuite.scala +++ b/atlas-cloudwatch/src/test/scala/com/netflix/atlas/cloudwatch/PublishRouterSuite.scala @@ -26,8 +26,6 @@ import com.typesafe.config.ConfigFactory import munit.FunSuite import org.mockito.MockitoSugar.mock -import scala.jdk.CollectionConverters.CollectionHasAsScala - class PublishRouterSuite extends FunSuite with TestKitBase { override implicit def system: ActorSystem = ActorSystem(getClass.getSimpleName)