Ignore error on "emit()" for each client socket

droonga · Oct 21, 2013 · 6aef488 · 6aef488
1 parent e216cb9
commit 6aef488
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/lib/adapter/socket.io.js b/lib/adapter/socket.io.js
@@ -139,8 +139,13 @@ exports.register = function(application, server, params) {
       subscribers = [subscribers];
     subscribers.forEach(function(subscriber) {
       subscriber = watchSubscribers[subscriber];
-      if (subscriber)
+      if (!subscriber)
+        return;
+      try {
         subscriber.emit('watch.notification', envelope.body);
+      } catch(exception) {
+        console.log(exception + '\n' + exception.stack);
+      }
     });
   };
   connection.on('watch.notification', watchNotificationHandler);