Browse Source

sparkplug: validate namespace1

pull/8159/head
nickAS21 4 years ago
parent
commit
07d9748098
  1. 4
      common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/util/sparkplug/SparkplugTopicUtil.java

4
common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/util/sparkplug/SparkplugTopicUtil.java

@ -109,8 +109,8 @@ public class SparkplugTopicUtil {
* @return * @return
*/ */
private static String validateNameSpace(String nameSpace) throws ThingsboardException { private static String validateNameSpace(String nameSpace) throws ThingsboardException {
if ("spBv1.0".equals(nameSpace)) return nameSpace; if (NAMESPACE.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); throw new ThingsboardException("The namespace [" + nameSpace + "] is not valid and must be [" + NAMESPACE + "] for the Sparkplug™ B version.", ThingsboardErrorCode.INVALID_ARGUMENTS);
} }
} }

Loading…
Cancel
Save