diff --git a/lib/handlers/subscribe.js b/lib/handlers/subscribe.js index 86d24b5c..880c5b7f 100644 --- a/lib/handlers/subscribe.js +++ b/lib/handlers/subscribe.js @@ -75,6 +75,10 @@ function storeSubscriptions (sub, done) { return done(null, sub) } + if (client.clean) { + return done(null, sub) + } + perst.addSubscriptions(client, packet.subscriptions, function (err) { done(err, sub) })