move publishSubscriptions check out of callback

moscajs · Apr 16, 2016 · 6a5cfa5 · 6a5cfa5
1 parent 798fb0d
commit 6a5cfa5
Showing 1 changed file with 6 additions and 8 deletions.
diff --git a/lib/server.js b/lib/server.js
@@ -262,29 +262,27 @@ function Server(opts, callback) {
     );
   });
 
-  that.on("subscribed", function(topic, client) {
-    if(that.modernOpts.publishSubscriptions) {
+  if(that.modernOpts.publishSubscriptions) {
+    that.on("subscribed", function(topic, client) {
       that.publish({
         topic: "$SYS/" + that.id + "/new/subscribes",
         payload: JSON.stringify({
           clientId: client.id,
           topic: topic
         })
       });
-    }
-  });
+    });
 
-  that.on("unsubscribed", function(topic, client) {
-    if(that.modernOpts.publishSubscriptions) {
+    that.on("unsubscribed", function(topic, client) {
       that.publish({
         topic: "$SYS/" + that.id + "/new/unsubscribes",
         payload: JSON.stringify({
           clientId: client.id,
           topic: topic
         })
       });
-    }
-  });
+    });
+  }
 
   that.on("clientDisconnected", function(client) {
     if(that.modernOpts.publishClientDisconnect) {