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 +