Building Scalable Apps with Redis and Node.js

Our first message queue

Now that we have a working RabbitMQ server, let's use it to build something. We will create a simple web server that will add a message to a queue on each request. We will also have a worker script that will work the queue.

First, create a new directory named rabbit_first. Create a package.json file and add the following code to it:

{
  "dependencies": {
    "amqp": "0.2.0"
  }
}

Then, run npm install. After this command finishes, create the app.js file and add the following code to it:

var http = require('http'), amqp = require('amqp'); var rabbit = amqp.createConnection(); rabbit.on('ready', function(){ rabbit.exchange('my-first-exchange', {type: 'direct', autoDelete: false}, function(ex){ startServer(ex); }); }); function startServer(ex) ...