diff --git a/src/pubsub.js b/src/pubsub.js index 6f2af3dae8..59ab8507c9 100644 --- a/src/pubsub.js +++ b/src/pubsub.js @@ -18,11 +18,15 @@ function get() { } else if (nconf.get('singleHostCluster')) { pubsub = new EventEmitter(); pubsub.publish = function (event, data) { - process.send({ - action: 'pubsub', - event: event, - data: data, - }); + if (process.send) { + process.send({ + action: 'pubsub', + event: event, + data: data, + }); + } else { + pubsub.emit(event, data); + } }; process.on('message', function (message) { if (message && typeof message === 'object' && message.action === 'pubsub') {