Bull Queue Hello World

readme.md

Bull Queue Hello World

run redis server

docker-compose up

run consumer as listener

node consumer.js

run producer as job creator

node producer.js

consumer.js

const Queue = require('bull')
const q = new Queue('my-first-queue', {
    redis: { port: 6379, host: "localhost" }
})

q.process((job, done) => {
    done(null, 'succes')
})

q.on('completed', (job) => {
    console.info(
        `${job.queue.name} task has been completed with message: "${job.data.message}" on: ${new Date().toLocaleTimeString()}`
    )
    job.remove()
})

docker-compose.yml

version: "3.9"
services:
  redis:
    image: redis:6-alpine
    ports:
      - 6379:6379

producer.js

const Queue = require('bull')
const q = new Queue('my-first-queue', {
    redis: { port: 6379, host: "localhost" }
})

const data = { message: "my task" }
q.add(data).then((v) => {
    console.info("task has been added with message:", v.data.message)
})