diff --git a/test/tap/multiprocess-shutdown-test.js b/test/tap/multiprocess-shutdown-test.js index fe18bb0..e4b014a 100644 --- a/test/tap/multiprocess-shutdown-test.js +++ b/test/tap/multiprocess-shutdown-test.js @@ -119,18 +119,17 @@ test('multiprocess appender crash (worker)', (t) => { categories: { default: { appenders: ['multi'], level: 'debug' } } }); - setTimeout(() => { - const worker = childProcess.fork( - require.resolve('./multiprocess-worker'), - ['start-multiprocess-worker', loggerPort] - ); - - setTimeout(() => { + const worker = childProcess.fork( + require.resolve('./multiprocess-worker'), + ['start-multiprocess-worker', loggerPort] + ); + worker.on('message', (m) => { + if (m === 'worker is done') { worker.kill(); setTimeout(() => { t.equal(messages[0], 'Logging from worker'); log4jsWithFakeConsole.shutdown(() => t.end()); - }, 250); - }, 250); - }, 250); + }, 500); + } + }); }); diff --git a/test/tap/multiprocess-worker.js b/test/tap/multiprocess-worker.js index c5b4b7c..a688b0a 100644 --- a/test/tap/multiprocess-worker.js +++ b/test/tap/multiprocess-worker.js @@ -8,4 +8,5 @@ if (process.argv.indexOf('start-multiprocess-worker') >= 0) { categories: { default: { appenders: ['multi'], level: 'debug' } } }); log4js.getLogger('worker').info('Logging from worker'); + process.send('worker is done'); }