Communication between microservices - RabbitMQ - Producer

producer.js

const amqp = require('amqplib')

async function createConnection (uri = 'guest:guest@localhost:5672') {
  const connection = await amqp.connect('amqp://' + uri)
  return connection
}

createConnection()
  .then(conn => conn.createChannel())
  .then(ch => {
    console.log('Channel created!')

    const queue = 'messages'
    ch.assertQueue(queue)
    setInterval(() => {
      console.log('-> Sending message')
      ch.sendToQueue(queue, Buffer.from('Message of example'))
    }, 1000)
  })