diff --git a/lib/persistence/levelup.js b/lib/persistence/levelup.js index 814fb89..a5a2d23 100644 --- a/lib/persistence/levelup.js +++ b/lib/persistence/levelup.js @@ -164,10 +164,8 @@ LevelUpPersistence.prototype.storeSubscriptions = function(client, done) { if (!client.clean) { // Issue #693 Object.keys(client.subscriptions).forEach(function(key) { - //if (client.subscriptions[key].qos > 0) { // Issue #693 subscriptions[key] = client.subscriptions[key]; subscriptions[key].ttl = that.options.ttl.subscriptions + now; - //} // Issue #693 }); this._clientSubscriptions.put(client.id, subscriptions, done); Object.keys(subscriptions).forEach(function(key) { diff --git a/lib/persistence/redis.js b/lib/persistence/redis.js index 3d1dab0..e18d077 100644 --- a/lib/persistence/redis.js +++ b/lib/persistence/redis.js @@ -285,9 +285,7 @@ RedisPersistence.prototype.storeSubscriptions = function(client, cb) { // Issue #693 Object.keys(client.subscriptions).forEach(function(key) { - // if (client.subscriptions[key].qos > 0) { // Issue #693 subscriptions[key] = client.subscriptions[key]; - //} // Issue #693 }); this._client.get(clientSubKey, function(err, currentSubs){