Revert "Fixed MQTT topic rewriting support."

This reverts commit 131dc05.
moscajs · Jul 17, 2013 · 3f982e6 · 3f982e6
1 parent af6f34b
commit 3f982e6
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 12 deletions.
diff --git a/lib/behave_like_an_ascoltatore.js b/lib/behave_like_an_ascoltatore.js
@@ -73,11 +73,7 @@ module.exports = function() {
 
   it("should support multi-level wildcard at start of topic", function(done) {
     var that = this;
-    var sub = function() {
-      that.instance.unsub("*/hello", sub, done);
-    };
-
-    that.instance.sub("*/hello", sub, function() {
+    that.instance.sub("*/hello", wrap(done), function() {
       that.instance.pub("42/there/hello");
     });
   });

diff --git a/lib/mqtt_ascoltatore.js b/lib/mqtt_ascoltatore.js
@@ -69,14 +69,7 @@ MQTTAscoltatore.prototype._startConn = function() {
       // we need to skip out this callback, so we do not
       // break the client when an exception occurs
       util.defer(function() {
-        var other;
-        if (topic.indexOf("/").length === 0) {
-          other = topic.substr(1);
-        } else {
-          other = "/" + topic;
-        }
         that._ascoltatore.publish(topic, payload, packet);
-        that._ascoltatore.publish(other, payload, packet);
       });
     });
     this._client.on('error', function(e) {