From 86e60de73ee1274dde439544fbf7ab7880ec84f2 Mon Sep 17 00:00:00 2001 From: Alvaro Vega Date: Wed, 16 Mar 2022 15:24:14 +0100 Subject: [PATCH] remove support to send mqtt to agent wihtout protocol --- lib/bindings/MQTTBinding.js | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/lib/bindings/MQTTBinding.js b/lib/bindings/MQTTBinding.js index 0ec02c3f..9ec4844f 100644 --- a/lib/bindings/MQTTBinding.js +++ b/lib/bindings/MQTTBinding.js @@ -47,7 +47,7 @@ function generateTopics(callback) { config.getLogger().debug(context, 'Generating topics'); // With leading slashes - topics.push(constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/+/+/' + constants.MEASURES_SUFIX + '/+'); + //topics.push(constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/+/+/' + constants.MEASURES_SUFIX + '/+'); topics.push( constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/' + @@ -56,7 +56,7 @@ function generateTopics(callback) { constants.MEASURES_SUFIX + '/+' ); - topics.push(constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/+/+/' + constants.MEASURES_SUFIX); + //topics.push(constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/+/+/' + constants.MEASURES_SUFIX); topics.push( constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/' + @@ -80,7 +80,7 @@ function generateTopics(callback) { '/' + constants.CONFIGURATION_COMMAND_SUFIX ); - topics.push(constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/+/+/' + constants.CONFIGURATION_COMMAND_UPDATE); + // topics.push(constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/+/+/' + constants.CONFIGURATION_COMMAND_UPDATE); topics.push( constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/' + @@ -90,7 +90,7 @@ function generateTopics(callback) { ); //Without leading slashes - topics.push(constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/+/+/' + constants.MEASURES_SUFIX + '/+'); + // topics.push(constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/+/+/' + constants.MEASURES_SUFIX + '/+'); topics.push( constants.MQTT_SHARE_SUBSCRIPTION_GROUP + constants.MQTT_TOPIC_PROTOCOL + @@ -98,7 +98,7 @@ function generateTopics(callback) { constants.MEASURES_SUFIX + '/+' ); - topics.push(constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/+/+/' + constants.MEASURES_SUFIX); + //topics.push(constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/+/+/' + constants.MEASURES_SUFIX); topics.push( constants.MQTT_SHARE_SUBSCRIPTION_GROUP + constants.MQTT_TOPIC_PROTOCOL + '/+/+/' + constants.MEASURES_SUFIX ); @@ -117,7 +117,7 @@ function generateTopics(callback) { '/' + constants.CONFIGURATION_COMMAND_SUFIX ); - topics.push(constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/+/+/' + constants.CONFIGURATION_COMMAND_UPDATE); + //topics.push(constants.MQTT_SHARE_SUBSCRIPTION_GROUP + '/+/+/' + constants.CONFIGURATION_COMMAND_UPDATE); topics.push( constants.MQTT_SHARE_SUBSCRIPTION_GROUP + constants.MQTT_TOPIC_PROTOCOL +