diff --git a/lib/appenders/multiprocess.js b/lib/appenders/multiprocess.js index e1deae9..0007829 100644 --- a/lib/appenders/multiprocess.js +++ b/lib/appenders/multiprocess.js @@ -119,13 +119,12 @@ function workerAppender(config) { canWrite = true; }); socket.on('timeout', socket.end.bind(socket)); - // don't bother listening for 'error', 'close' gets called after that anyway - socket.on('close', createSocket); socket.on('error', (e) => { debug('connection error', e); canWrite = false; emptyBuffer(); }); + socket.on('close', createSocket); } createSocket();