From 07d9748098eb8b3382c54594a723a0527c1352b3 Mon Sep 17 00:00:00 2001 From: nickAS21 Date: Thu, 2 Mar 2023 13:27:38 +0200 Subject: [PATCH] sparkplug: validate namespace1 --- .../transport/mqtt/util/sparkplug/SparkplugTopicUtil.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/util/sparkplug/SparkplugTopicUtil.java b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/util/sparkplug/SparkplugTopicUtil.java index b727db7a08..58b4319781 100644 --- a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/util/sparkplug/SparkplugTopicUtil.java +++ b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/util/sparkplug/SparkplugTopicUtil.java @@ -109,8 +109,8 @@ public class SparkplugTopicUtil { * @return */ private static String validateNameSpace(String nameSpace) throws ThingsboardException { - if ("spBv1.0".equals(nameSpace)) return nameSpace; - throw new ThingsboardException("The namespace [" + nameSpace + "] is not valid and must be [spBv1.0] for the Sparkplug™ B version.", ThingsboardErrorCode.INVALID_ARGUMENTS); + if (NAMESPACE.equals(nameSpace)) return nameSpace; + throw new ThingsboardException("The namespace [" + nameSpace + "] is not valid and must be [" + NAMESPACE + "] for the Sparkplug™ B version.", ThingsboardErrorCode.INVALID_ARGUMENTS); } }