Publish/Subscribe tutorial receive_logs.js

Author: priviterag

javascript-nodejs/src/receive_logs.js

@@ -4,29 +4,31 @@ var amqp = require('amqplib');
 
 var conn = amqp.connect('amqp://localhost')
 
-conn.then(createChannel).then(null, console.warn);
+var ch = conn.then(createChannel).then(null, console.warn);
 
-function createChannel(conn) {
-  process.once('SIGINT', function() { conn.close(); });
-  return conn.createChannel().then(function(ch) {
-    var ok = ch.assertExchange('logs', 'fanout', {durable: false});
-    ok = ok.then(function() {
-      return ch.assertQueue('', {exclusive: true});
-    });
-    ok = ok.then(function(qok) {
-      return ch.bindQueue(qok.queue, 'logs', '').then(function() {
-        return qok.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');
+ch.then(function(ch) {
+  var ok = ch.assertExchange('logs', 'fanout', {durable: false});
+  ok = ok.then(function() {
+    return ch.assertQueue('', {exclusive: true});
+  });
+  ok = ok.then(function(qok) {
+    return ch.bindQueue(qok.queue, 'logs', '').then(function() {
+      return qok.queue;
     });
-
-    function logMessage(msg) {
-      console.log(" [x] '%s'", msg.content.toString());
-    }
   });
+  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'", msg.content.toString());
+  }
+});
+
+function createChannel(conn) {
+  process.once('SIGINT', function() { conn.close(); });
+  return conn.createChannel();
 }