amqp pub-sub

amqp_pubsub.js

var cluster = require('cluster')
  , amqp = require('amqp');

if (cluster.isMaster) {
  for (var i = 0; i < 5; i++) cluster.fork();
  startPublisher();
} else {
  startSubscriber();
}

function startPublisher() {
  var conn = amqp.createConnection({host: 'localhost'});
  conn.on('ready', function () {
    var exc = conn.exchange('logs', {type: 'fanout'});

    exc.publish('', 'before');

    var cnt = 0;
    setInterval(function () {
      console.log('PUBLISHING');
      exc.publish('', 'hello world: ' + cnt++);
    }, 50);

  });
}

function startSubscriber() {
  var conn = amqp.createConnection({host: 'localhost'});
  conn.on('ready', function () {

    var exc = conn.exchange('logs', {type: 'fanout'});

    conn.queue('', {exclusive: true}, function (queue) {
      queue.bind(exc, '');

      queue.subscribe(function (message) {
        console.log(message.data.toString());
      });
    });

  });
}