Don't let JSON errors crash client

dshaw · Feb 6, 2011 · 3150ed0 · 3150ed0
1 parent f46a239
commit 3150ed0
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/index.js b/index.js
@@ -125,10 +125,12 @@ var Worker = function (options) {
       return self.emit('error', error);
     }
 
-    var data = JSON.parse(Buffer.isBuffer(data[1]) ? data[1].toString() : data),
-        job  = new Job(self, data);
+    try {
+      data = JSON.parse(Buffer.isBuffer(data[1]) ? data[1].toString() : data[1]);
+      var job  = new Job(self, data);
 
-    self.emit('message', job);
+      self.emit('message', job);
+    } catch (json_error) {}
 
     if (!self.client.quitting && self.continual) {
       // Listen for more jobs.