commit
7bacfb676e
|
@ -47,7 +47,9 @@ function createPool(options, clientpool) {
|
||||||
client.on('error', function (err) {
|
client.on('error', function (err) {
|
||||||
client.removeAllListeners('connect');
|
client.removeAllListeners('connect');
|
||||||
client.removeAllListeners('connectTimeout');
|
client.removeAllListeners('connectTimeout');
|
||||||
clientpool.emit('error', err);
|
if (clientpool.listeners('error').length) {
|
||||||
|
clientpool.emit('error', err);
|
||||||
|
}
|
||||||
return callback(err);
|
return callback(err);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue