|
|
@@ -192,9 +192,14 @@ module.exports = { |
|
|
|
return thread; |
|
|
|
}, |
|
|
|
onMessage: function (thread, message) { |
|
|
|
if (message.module) |
|
|
|
global[message.module][message.method](message); |
|
|
|
else if (message.event === 'onCrashed') { |
|
|
|
if (message.module) { |
|
|
|
try { |
|
|
|
global[message.module][message.method](message); |
|
|
|
} catch (e) { |
|
|
|
console.log('No global method found', message.module, message.method); |
|
|
|
process.exit(); |
|
|
|
} |
|
|
|
} else if (message.event === 'onCrashed') { |
|
|
|
thread.worker.kill(); |
|
|
|
process.exit(); |
|
|
|
} else |
|
|
@@ -332,4 +337,5 @@ module.exports = { |
|
|
|
}); |
|
|
|
}); |
|
|
|
} |
|
|
|
|
|
|
|
}; |