Sample Queue Implementation to achieve Asychronous Messaging communication

async_queue.js

var q = 'tasks';
 
var open = require('amqplib').connect('amqp://localhost');
 
// Publisher 
open.then(function(conn) {
  return conn.createChannel();
}).then(function(ch) {
  return ch.assertQueue(q).then(function(ok) {
    return ch.sendToQueue(q, new Buffer('something to do')); //Note : queue is filled up here
  });
}).catch(console.warn);
 
// Consumer 
open.then(function(conn) {
  return conn.createChannel();
}).then(function(ch) {                       //Note : Review queue and take actions accordingly
  return ch.assertQueue(q).then(function(ok) {
    return ch.consume(q, function(msg) {
      if (msg !== null) {
        console.log(msg.content.toString());
        ch.ack(msg);
      }
    });
  });
}).catch(console.warn);