AMQP Listener

listen.coffee

amqp = require('amqp');

connection = amqp.createConnection { host: 'localhost' }

# Wait for connection to become established.
connection.on 'ready', ()->
  exchange = connection.exchange 'phil-exchange'
  # Create a queue and bind to all messages.
  connection.queue 'phil-queue',{autoDelete:false,durable:true}, (q)->
      # Catch all messages
      q.bind('phil-exchange','#');

      # Receive messages
      q.subscribe {ack:true},(message)->
        # Print messages
        console.log(message.data.toString())
        q.shift()