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"));