From d15cb27ecf0df4e5c1caa0dcc5b6c7e0ba52e646 Mon Sep 17 00:00:00 2001
From: ViacheslavKlimov <viacheslavklimov11@gmail.com>
Date: Tue, 13 May 2025 15:19:24 +0300
Subject: [PATCH] Add queue prefix in msa tests

---
 .../test/java/org/thingsboard/server/msa/ContainerTestSuite.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/msa/black-box-tests/src/test/java/org/thingsboard/server/msa/ContainerTestSuite.java b/msa/black-box-tests/src/test/java/org/thingsboard/server/msa/ContainerTestSuite.java
index e00b0828c9..0573aee8fe 100644
--- a/msa/black-box-tests/src/test/java/org/thingsboard/server/msa/ContainerTestSuite.java
+++ b/msa/black-box-tests/src/test/java/org/thingsboard/server/msa/ContainerTestSuite.java
@@ -130,6 +130,7 @@ public class ContainerTestSuite {
 
             Map<String, String> queueEnv = new HashMap<>();
             queueEnv.put("TB_QUEUE_TYPE", QUEUE_TYPE);
+            queueEnv.put("TB_QUEUE_PREFIX", "test");
             switch (QUEUE_TYPE) {
                 case "kafka":
                     composeFiles.add(new File(targetDir + "docker-compose.kafka.yml"));