O'Reilly logo

Building Scalable Apps with Redis and Node.js by Joshua Johanan

Stay ahead with the world's most comprehensive technology and business learning platform.

With Safari, you learn the way you learn best. Get unlimited access to videos, live online training, learning paths, books, tutorials, and more.

Start Free Trial

No credit card required

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) ...

With Safari, you learn the way you learn best. Get unlimited access to videos, live online training, learning paths, books, interactive tutorials, and more.

Start Free Trial

No credit card required