This commit is contained in:
brow3c
2021-05-15 19:15:44 +09:00
parent bcd47c712c
commit 9598d9b6fe

View File

@@ -20,18 +20,18 @@ class PoolingService {
createPool() { createPool() {
setInterval(() => this.debugPoolStatus(), 1000 * 60 * 5) setInterval(() => this.debugPoolStatus(), 1000 * 60 * 5)
let pool = pool.createPool({ let genericPool = pool.createPool({
create: () => this.create(), create: () => this.create(),
destroy: (driver) => this.destroy(driver), destroy: (driver) => this.destroy(driver),
validate: (driver) => this.validate(driver) validate: (driver) => this.validate(driver)
}, this.config.pool); }, this.config.pool);
this.pool.on("factoryCreateError", function (err) { genericPool.on("factoryCreateError", function (err) {
logger.debug({reason: err.message}, 'factoryCreateError'); logger.debug({reason: err.message}, 'factoryCreateError');
}); });
this.pool.on("factoryDestroyError", function (err) { genericPool.on("factoryDestroyError", function (err) {
logger.debug({reason: err.message}, 'factoryDestroyError'); logger.debug({reason: err.message}, 'factoryDestroyError');
}); });
return pool return genericPool
} }
create() { create() {