Change Location of how to run link and fix text of how to install RabbitMQ

Author: learnercys

how-to-run.md

@@ -5,7 +5,7 @@
 * NodeJS.
 
 #### How to install RabbitMQ using docker
-Install docker run this command:
+Install docker and run this command:
 ```bash
 docker run -d --hostname my-rabbit --name some-rabbit -p 15672:15672 -p 5672:5672 rabbitmq:3-management
 ```
@@ -14,56 +14,56 @@ After that, you will be able to access to the management on `0.0.0.0:15672` or `
 
 ### Tutorial 1
 
-1. Open a terminal to run the consumer:
+* Open a terminal to run the consumer:
 ```bash
 # this will show: [*] Waiting for messages. To exit press CTRL+C
 $ node t1-basic-consumer.js
 ```
 
-2. Open other terminal to run the producer:
+* Open other terminal to run the producer:
 ```bash
 # this will show:  [x] Sent 'hello world'
 $ node t1-basic.js 'hello world.'
 ```
 
-3. Wait 3 seconds and then you will see `[x] Received 'hello world'` on the consumers terminal.
+* Wait 3 seconds and then you will see `[x] Received 'hello world'` on the consumers terminal.
 
 ### Tutorial 2
-1. Open the terminal to run the consumer:
+* Open the terminal to run the consumer:
 ```bash
 # this will show: [*] Waiting for logs. To exit press CTRL+C.
 $ node t2-direct-consumer.js SEVERITY
 ```
 
-2. Open other terminal to run the producer:
+* Open other terminal to run the producer:
 ```bash
 # this will show: [x] Sent SEVERITY:'hellow world'
 $ node t2-direct.js SEVERITY 'hello world'
 ```
 
 ### Tutorial 3
-1. Open the terminal to run the consumer:
+* Open the terminal to run the consumer:
 ```bash
 # This command will consume all the messages with a key that match with `logs.#`: `logs.info`, `logs.error`, `logs.warning`
 $ node t3-topics-consumer.js 'logs.#'
 ```
 
-2. Open other terminal to run the producer:
+* Open other terminal to run the producer:
 ```bash
 $ node t3-topics.js 'logs.info' 'information message'
 $ node t3-topics.js 'logs.error' 'error message'
 $ node t3-topics.js 'logs.warning' 'warning message'
 ```
 ### Tutotial 4
-1. Open the terminal to run the consumer:
+* Open the terminal to run the consumer:
 ```bash
 # this consumer will process events only that match with `logs.info`. Also
 # this consumer will only accept the messages equal to `hello` and reject the others.
 # All the messages rejected will be stored on `queue.dl`.
 $ node t4-deadletter-consumer.js 'logs.info'
 ```
 
-2. Open other terminal to runt the producer:
+* Open other terminal to runt the producer:
 ```bash
 # this message is accepted
 $ node t4-deadletter.js 'logs.info' 'hello'

readme.md

@@ -4,6 +4,9 @@ Advanced Message Queuing Protocol
 
 ***
 
+### How Run the Examples
+See the document [how-to-run.md](how-to-run.md)
+
 ### Producer
 Manage the messages to be published so they can be processed.
 
@@ -32,9 +35,6 @@ Rules used for the exchange to send messages to its linked queues.
 
 ***
 
-### How Run the Examples
-See the document [how-to-run.md](how-to-run.md)
-
 ### Reference:
 1. https://www.rabbitmq.com/tutorials/amqp-concepts.html
 2. http://www.squaremobius.net/amqp.node/channel_api.html

t1-basic-consumer.js

@@ -1,24 +1,24 @@
 var amqp = require('amqplib');
 
 amqp.connect('amqp://localhost').then(function (conn) {
-	return conn.createChannel().then(function (ch) {
-		// queue to consume
-		var q = 'queuet1';
+    return conn.createChannel().then(function (ch) {
+        // queue to consume
+        var q = 'queuet1';
 
-		// we need to make sure that the queue exists
-		var ok = ch.assertQueue(q, { durable: false});
+        // we need to make sure that the queue exists
+        var ok = ch.assertQueue(q, { durable: false});
 
-		ok = ok.then(function () {
-			// initialize the consume event 
-			return ch.consume(q, function (msg) {
-				setTimeout(function () {
-					console.log(" [x] Received '%s'", msg.content.toString());		
-				}, 3000);
-			}, { noAck: true });
-		});
+        ok = ok.then(function () {
+            // initialize the consume event 
+            return ch.consume(q, function (msg) {
+                setTimeout(function () {
+                    console.log(" [x] Received '%s'", msg.content.toString());      
+                }, 3000);
+            }, { noAck: true });
+        });
 
-		return ok.then(function (_consumeOk) {
-			console.log(' [*] Waiting for messages. To exit press CTRL+C');
-		});
-	});
+        return ok.then(function (_consumeOk) {
+            console.log(' [*] Waiting for messages. To exit press CTRL+C');
+        });
+    });
 }).then(null, console.warn);

t1-basic.js

@@ -13,25 +13,25 @@ var args = process.argv.slice(2);
 var msg = args[0] || 'hello world';
 
 amqp.connect('amqp://localhost').then(function(conn) {
-	// here we use `when` to ensure that the connection is closed 
-	// after the `sendToQueue` event
-	return when(conn.createChannel().then(function(ch) {
-		// this will be the name of our new queue.
-		var q = 'queuet1';
-
-		// we need to be sure that the queue `queuet1` exists
-		// if not, the `assertQueue` method create it.
-		var ok = ch.assertQueue(q, {durable: false});
-
-		return ok.then(function(_qok) {
-			// after create | validate the existence of the queue
-			// we are ready to publish messages to it.
-			ch.sendToQueue(q, new Buffer(msg));
-			console.log(" [x] Sent '%s'", msg);
-
-			// we shouldn't need the channel anymore.
-			return ch.close();
-		});
-	})).ensure(function () { conn.close(); });
+    // here we use `when` to ensure that the connection is closed 
+    // after the `sendToQueue` event
+    return when(conn.createChannel().then(function(ch) {
+        // this will be the name of our new queue.
+        var q = 'queuet1';
+
+        // we need to be sure that the queue `queuet1` exists
+        // if not, the `assertQueue` method create it.
+        var ok = ch.assertQueue(q, {durable: false});
+
+        return ok.then(function(_qok) {
+            // after create | validate the existence of the queue
+            // we are ready to publish messages to it.
+            ch.sendToQueue(q, new Buffer(msg));
+            console.log(" [x] Sent '%s'", msg);
+
+            // we shouldn't need the channel anymore.
+            return ch.close();
+        });
+    })).ensure(function () { conn.close(); });
 }).then(null, console.warn);
 

t2-direct-consumer.js

@@ -5,35 +5,35 @@ var args = process.argv.slice(2);
 var severity = args[0] || 'info';
 
 amqp.connect('amqp://localhost').then(function(conn) {
-	process.once('SIGINT', function() { conn.close(); });
+    process.once('SIGINT', function() { conn.close(); });
 
-	return conn.createChannel().then(function(ch) {
-		var ex = 'direct_logs';
+    return conn.createChannel().then(function(ch) {
+        var ex = 'direct_logs';
 
-		var ok = ch.assertExchange(ex, 'direct', {durable: false});
+        var ok = ch.assertExchange(ex, 'direct', {durable: false});
 
-		ok = ok.then(function() {
-			return ch.assertQueue('', {exclusive: true});
-		});
+        ok = ok.then(function() {
+            return ch.assertQueue('', {exclusive: true});
+        });
 
-		ok = ok.then(function(qok) {
-			var queue = qok.queue;
-			
-			return ch.bindQueue(queue, ex, severity).then(function() { return queue; });
-		});
+        ok = ok.then(function(qok) {
+            var queue = qok.queue;
+            
+            return ch.bindQueue(queue, ex, severity).then(function() { return queue; });
+        });
 
-		ok = ok.then(function(queue) {
-			return ch.consume(queue, logMessage, {noAck: true});
-		});
+        ok = ok.then(function(queue) {
+            return ch.consume(queue, logMessage, {noAck: true});
+        });
 
-		return ok.then(function() {
-			console.log(' [*] Waiting for logs. To exit press CTRL+C.');
-		});
+        return ok.then(function() {
+            console.log(' [*] Waiting for logs. To exit press CTRL+C.');
+        });
 
-		function logMessage(msg) {
-			console.log(" [x] %s:'%s'",
-									msg.fields.routingKey,
-									msg.content.toString());
-		}
-	});
+        function logMessage(msg) {
+            console.log(" [x] %s:'%s'",
+                                    msg.fields.routingKey,
+                                    msg.content.toString());
+        }
+    });
 }).then(null, console.warn);

t2-direct.js

@@ -9,16 +9,16 @@ var severity = args[0] || 'info';
 var message = args[1] || 'Hello World!';
 
 amqp.connect('amqp://localhost').then(function(conn) {
-	return when(conn.createChannel().then(function(ch) {
-		// the exchange name used to receive all the messages
-		var ex = 'direct_logs';
+    return when(conn.createChannel().then(function(ch) {
+        // the exchange name used to receive all the messages
+        var ex = 'direct_logs';
 
-		var ok = ch.assertExchange(ex, 'direct', {durable: false});
+        var ok = ch.assertExchange(ex, 'direct', {durable: false});
 
-		return ok.then(function() {
-			ch.publish(ex, severity, new Buffer(message));
-			console.log(" [x] Sent %s:'%s'", severity, message);
-			return ch.close();
-		});
-	})).ensure(function() { conn.close(); });
+        return ok.then(function() {
+            ch.publish(ex, severity, new Buffer(message));
+            console.log(" [x] Sent %s:'%s'", severity, message);
+            return ch.close();
+        });
+    })).ensure(function() { conn.close(); });
 }).then(null, console.warn);

t3-topics-consumer.js

@@ -4,31 +4,31 @@ var amqp = require('amqplib');
 var key = process.argv[2] || 'log.info';
 
 amqp.connect('amqp://localhost').then(function (conn) {
-	process.once('SIGINT', function() { conn.close(); });
+    process.once('SIGINT', function() { conn.close(); });
 
-	return conn.createChannel().then(function(ch) {
-		var ex = 'topic_logs';
-		var ok = ch.assertExchange(ex, 'topic', {durable: false});
-		
-		ok = ok.then(function() {
-			return ch.assertQueue('', {exclusive: true});
-		});
-		
-		ok = ok.then(function(qok) {
-			var queue = qok.queue;
-			return ch.bindQueue(queue, ex, key).then(function() { return queue; });
-		});
-		
-		ok = ok.then(function(queue) {
-			return ch.consume(queue, logMessage, {noAck: true});
-		});
+    return conn.createChannel().then(function(ch) {
+        var ex = 'topic_logs';
+        var ok = ch.assertExchange(ex, 'topic', {durable: false});
+        
+        ok = ok.then(function() {
+            return ch.assertQueue('', {exclusive: true});
+        });
+        
+        ok = ok.then(function(qok) {
+            var queue = qok.queue;
+            return ch.bindQueue(queue, ex, key).then(function() { return queue; });
+        });
+        
+        ok = ok.then(function(queue) {
+            return ch.consume(queue, logMessage, {noAck: true});
+        });
 
-		return ok.then(function() {
-			console.log(' [*] Waiting for logs. To exit press CTRL+C.');
-		});
-		
-		function logMessage(msg) {
-			console.log(" [x] %s:'%s'", msg.fields.routingKey, msg.content.toString());
-		}
-	});
+        return ok.then(function() {
+            console.log(' [*] Waiting for logs. To exit press CTRL+C.');
+        });
+        
+        function logMessage(msg) {
+            console.log(" [x] %s:'%s'", msg.fields.routingKey, msg.content.toString());
+        }
+    });
 }).then(null, console.warn);

t3-topics.js

@@ -7,17 +7,17 @@ var key = args[0] || 'log.info';
 var message = args[1] || 'Hello World!';
 
 amqp.connect('amqp://localhost').then(function(conn) {
-	return when(conn.createChannel().then(function(ch) {
-		var ex = 'topic_logs';
-		var ok = ch.assertExchange(ex, 'topic', {durable: false});
+    return when(conn.createChannel().then(function(ch) {
+        var ex = 'topic_logs';
+        var ok = ch.assertExchange(ex, 'topic', {durable: false});
 
-		ok = ok.then(function() {
-			return ch.publish(ex, key, new Buffer(message));
-		});
+        ok = ok.then(function() {
+            return ch.publish(ex, key, new Buffer(message));
+        });
 
-		return ok.then(function() {
-			console.log(" [x] Sent %s:'%s'", key, message);
-			return ch.close();
-		});
-	})).ensure(function() { conn.close(); })
+        return ok.then(function() {
+            console.log(" [x] Sent %s:'%s'", key, message);
+            return ch.close();
+        });
+    })).ensure(function() { conn.close(); })
 }).then(null, console.log);