ampq.pubconsume.js

let workOnChannel = async (channel) => {
  // ...
  
  //Consumer listening to the queue, which was ealier created and bind with exchange
  let { consumerTag } = await channel.consume(queue, function (msg) {
        if (msg.content) {
            let dataReceive = JSON.parse(msg.content.toString());
            console.log(`[✓] Incomming message ${JSON.stringify(dataReceive)}`);
        }
    }, {
        noAck: true
    });
  
  //Publisher pushing messages to the 'exchange' which was earlier defined 
  //Dummy data block
  let data = {
        message: "This is a sample message",
        action: "nothing"
    }
  channel.publish(exchange, '', Buffer.from(JSON.stringify(data)));
  // channel.sendToQueue(sessionId, Buffer.from(JSON.stringify(data)));
  console.log(`[!] Data Pushed to ${exchange}`)
  
}