gistfile1.js

var amqp = require('amqp');
var conn = amqp.createConnection();
conn.once('ready', function() {
  console.log('conn ready');
  conn.queue('queue', function(q) {
    console.log('queue open');
    q.subscribe(function(message) {
      console.log(message);
      whoops;
    });
    var ex = conn.exchange('ex');
    ex.once('open', function() {
      console.log('exchange open');
      q.bind(ex, 'queue');
      ex.publish('queue', 'message');
      whoops;
    });
    whoops;
  });
  whoops;
});