From 7b451e59fa95417ee390c9034dae96be09aeac4a Mon Sep 17 00:00:00 2001
From: Arnout Engelen <arnout@bzzt.net>
Date: Sun, 9 Feb 2025 11:34:16 +0100
Subject: [PATCH] test: avoid topic overlap between Mqtt tests

Avoid multiple tests using the same topic.

Possibly towards avoiding #468
---
 .../src/test/java/docs/javadsl/MqttFlowTest.java          | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/mqtt-streaming/src/test/java/docs/javadsl/MqttFlowTest.java b/mqtt-streaming/src/test/java/docs/javadsl/MqttFlowTest.java
index 4b0b5d614..68a08def3 100644
--- a/mqtt-streaming/src/test/java/docs/javadsl/MqttFlowTest.java
+++ b/mqtt-streaming/src/test/java/docs/javadsl/MqttFlowTest.java
@@ -100,8 +100,8 @@ public void assertStageStopping() {
   @Test
   public void establishClientBidirectionalConnectionAndSubscribeToATopic()
       throws InterruptedException, ExecutionException, TimeoutException {
-    String clientId = "source-test/flow";
-    String topic = "source-test/topic1";
+    String clientId = "client-flow-test/flow";
+    String topic = "client-flow-test/topic1";
     ByteString uniqueSessionId = ByteString.fromString("establishClientBidirectionalConnectionAndSubscribeToATopic-session");
 
     // #create-streaming-flow
@@ -161,8 +161,8 @@ public Publish apply(DecodeErrorOrEvent<Object> x, boolean isCheck) {
   @Test
   public void establishServerBidirectionalConnectionAndSubscribeToATopic()
       throws InterruptedException, ExecutionException, TimeoutException {
-    String clientId = "flow-test/flow";
-    String topic = "source-test/topic1";
+    String clientId = "server-flow-test/flow";
+    String topic = "server-flow-test/topic1";
     ByteString uniqueSessionId = ByteString.fromString("establishServerBidirectionalConnectionAndSubscribeToATopic-connection");
     String host = "localhost";
     int port = 9884;