index.js

const express    = require('express');
const bodyParser = require('body-parser');
const amqp       = require('amqplib');

const q = 'tasks';

var app = express();
app.use(bodyParser.json());

// Publisher
var open = amqp.connect('amqp://localhost');
open.then((conn) => {
  return conn.createChannel();
}).then((ch) => {
  return ch.assertQueue(q).then((ok) => {
    app.post('/data', (req, res) => {
      ch.sendToQueue(q, new Buffer(JSON.stringify(req.body)));
      res.end();
    });

    app.listen('3000');
  });
}).catch(console.warn);

// Consumer
open.then(function(conn) {
  return conn.createChannel();
}).then(function(ch) {
  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);