test.js

var amqp = require('./amqp');


var connection = amqp.createConnection({host: 'localhost'});


connection.addListener('close', function (e) {
  if (e) {
    throw e;
  } else {
    console.log('connection closed.');
  }
});


connection.addListener('ready', function () {
  console.log('connected to ' + connection.serverProperties.product);

  var exchange = connection.exchange('clock', {type: 'fanout'});

  var q = connection.queue('my-events-receiver');

  q.bind(exchange, "*").addCallback(function () {
    console.log('publishing message');
    exchange.publish('message.json', {hello: 'world', foo: 'bar'});
    exchange.publish('message.text', 'hello world', {contentType: 'text/plain'});
  });

  q.subscribe(function (m) {
    console.log('--- Message (' + m.deliveryTag + ", '" + m.routingKey + "') ---");
    console.log('--- contentType: ' + m.contentType);

    m.addListener('data', function (d) {
      console.log(d);
    });

    m.addListener('end', function () {
      m.acknowledge();
      console.log('--- END (' + m.deliveryTag + ", '" + m.routingKey + "') ---");
    });
  });
});