En el siguiente ejemplo de código, intento enviar sampleQueue1, sampleQueue2, sampleQueue3 pero recibo un error.

 const Queue = require('bull'); const sampleQueue1 = new Queue('sample1', 'redis://127.0.0.1:6379'); const sampleQueue2 = new Queue('sample2', 'redis://127.0.0.1:6379'); const sampleQueue3 = new Queue('sample3', 'redis://127.0.0.1:6379'); const delay = ms => new Promise(resolve => setTimeout(resolve, ms)); const queueProcess = async(job, done) => { console.log(job.data); await delay(5 * 1000); job.log("Testing Log"); if(job.data % 2 == 0) done(null, "even number"); else done(new Error('error transcoding')); } sampleQueue1.process(queueProcess); sampleQueue2.process(queueProcess); sampleQueue3.process(queueProcess); let queues = [sampleQueue1, sampleQueue2, sampleQueue3] (async() => { await sampleQueue.obliterate({ force: true }); array = [11, 12, 13, 14, 15, 16, 17, 18, 19, 20] array.forEach(val => { console.log(val); let rand = Math.floor(Math.random() * queues.length); queues[rand].add(val); }); })(); console.log("Job done");

Cuando ejecuto el código anterior, recibo el siguiente error:

 /test.js:16 (async() => { ^ TypeError: [sampleQueue] is not a function

Ayúdame a solucionar este problema.