Skip to content
This repository has been archived by the owner on Jul 18, 2020. It is now read-only.

Commit

Permalink
fix: fixed max listener issue
Browse files Browse the repository at this point in the history
  • Loading branch information
niftylettuce committed Jul 6, 2020
1 parent ff138cf commit ff839be
Show file tree
Hide file tree
Showing 3 changed files with 700 additions and 761 deletions.
13 changes: 9 additions & 4 deletions index.js
Original file line number Diff line number Diff line change
Expand Up @@ -51,19 +51,25 @@ class Bull {
this.client = new Redis(
this.config.queue.redis,
this.config.logger,
this.config.redisMonitor
this.config.redisMonitor,
this.config.queueMaxListeners,
false
);

this.eclient = new Redis(
this.config.queue.redis,
this.config.logger,
this.config.redisMonitor
this.config.redisMonitor,
this.config.queueMaxListeners,
false
);

this.bclient = new Redis(
this.config.queue.redis,
this.config.logger,
this.config.redisMonitor
this.config.redisMonitor,
this.config.queueMaxListeners,
false
);

// Map<key, Queue>
Expand Down Expand Up @@ -262,7 +268,6 @@ class Bull {

// <https://github.com/OptimalBits/bull/issues/1659>
queue.removeAllListeners('error');
queue.setMaxListeners(this.config.queueMaxListeners);

queue
.on('error', err => {
Expand Down
16 changes: 8 additions & 8 deletions package.json
Original file line number Diff line number Diff line change
Expand Up @@ -25,17 +25,17 @@
"Shaun Warman <shaunwarman1@gmail.com> (https://shaunwarman.com)"
],
"dependencies": {
"@ladjs/redis": "^1.0.4",
"@ladjs/shared-config": "^3.0.8",
"@ladjs/redis": "^1.0.5",
"@ladjs/shared-config": "^3.0.9",
"auto-bind": "^4.0.0",
"bull": "^3.14.0",
"bull": "^3.15.0",
"is-string-and-not-blank": "^0.0.2",
"lodash": "^4.17.15"
},
"devDependencies": {
"@commitlint/cli": "^8.3.5",
"@commitlint/config-conventional": "^8.3.4",
"ava": "^3.9.0",
"@commitlint/cli": "^9.0.1",
"@commitlint/config-conventional": "^9.0.1",
"ava": "^3.10.0",
"codecov": "^3.7.0",
"cross-env": "^7.0.2",
"delay": "^4.3.0",
Expand All @@ -44,11 +44,11 @@
"eslint-plugin-node": "^11.1.0",
"fixpack": "^3.0.6",
"husky": "^4.2.5",
"lint-staged": "^10.2.10",
"lint-staged": "^10.2.11",
"ms": "^2.1.2",
"nyc": "^15.1.0",
"remark-cli": "^8.0.0",
"remark-preset-github": "^1.0.1",
"remark-preset-github": "^2.0.2",
"xo": "0.25"
},
"engines": {
Expand Down
Loading

0 comments on commit ff839be

Please sign in to comment.