fix: multiple mqtt as the same

stellio-hub · Jul 12, 2024 · d53f460 · d53f460
1 parent d207be0
commit d53f460
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...vice/src/main/kotlin/com/egm/stellio/subscription/service/mqtt/MqttNotificationService.kt b/...vice/src/main/kotlin/com/egm/stellio/subscription/service/mqtt/MqttNotificationService.kt
@@ -13,6 +13,7 @@ import org.eclipse.paho.mqttv5.client.MqttConnectionOptions
 import org.slf4j.LoggerFactory
 import org.springframework.beans.factory.annotation.Value
 import org.springframework.stereotype.Service
+import java.util.*
 import org.eclipse.paho.client.mqttv3.MqttException as MqttExceptionV3
 import org.eclipse.paho.mqttv5.common.MqttException as MqttExceptionV5
 
@@ -49,7 +50,7 @@ class MqttNotificationService(
             message = MqttNotificationData.MqttMessage(notification, headers),
             connection = MqttConnectionData(
                 brokerUrl = brokerUrl,
-                clientId = clientId,
+                clientId = "${clientId}_${UUID.randomUUID()}",
                 username = username,
                 password = password
             )