Open bahatron opened 6 years ago
const queue = kue.createQueue({ ... })
queue.setMaxListeners(1000) // <- golden method
queue.on('error', function (err) {
...
Instead of blindly setting Max Listeners to 1000, you can do :
queue.setMaxListeners(queue.getMaxListeners() + 1);
whenever you add a processor to the queue.
If you are using Concurrency, Just add the concurrency value you are using instead of 1.
In your case, you can just do:
queue.setMaxListeners(queue.getMaxListeners() + Object.keys($jobs).length);
before the loop.
Will do!. Thank you
any other way to fix this?
any other way to fix this?
@sibelius Could you provide a code sample with which you are getting this (after increaseing listeners with setMaxListeners
)?
I'm getting
(node:38) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 job ttl exceeded listeners added. Use emitter.setMaxListeners() to increase limit
my Kue implementation:
a job declaration example
job registration
whole project here: https://github.com/AddToEvent/JobProcessor
Kue version:
0.11.6
I'm using docker images to launch my app