diff --git a/lib/monitor/run.js b/lib/monitor/run.js index 4c74d338..59a339da 100644 --- a/lib/monitor/run.js +++ b/lib/monitor/run.js @@ -133,6 +133,12 @@ function run(options) { bus.stdout = child.stdout; bus.stderr = child.stderr; } + + if (shouldFork) { + child.on('message', function (message, sendHandle) { + bus.emit('message', message, sendHandle); + }); + } } bus.emit('start');