RabbitMQ Pub-Sub

consumer.js

const amqp = require('amqplib')

const connect = async () => {
  try {
    const connection = await amqp.connect('amqp://localhost:5672')
    const channel = await connection.createChannel()

    const result = await channel.assertQueue('jobs')

    channel.consume('jobs', (message) => {
      const data = JSON.parse(message.content.toString())
      console.log(data.number)

      if (data.number == 10) {
        console.log(`Consumed ${data.number}`)
        channel.ack(message)
      }
    })

    return console.log('Waiting for Messages')
  } catch (err) {
    console.log(err)
  }
}

connect()

publisher.js

const amqp = require('amqplib')

const message = { number: process.argv[2] }

async function connect() {
  try {
    const connection = await amqp.connect('amqp://localhost:5672')
    const channel = await connection.createChannel()

    const result = await channel.assertQueue('jobs')
    channel.sendToQueue('jobs', Buffer.from(JSON.stringify(message)))

    return console.log('Job Sent Successfully')
  } catch (err) {
    console.log(err)
  }
}

connect()