Await binding declaration

While at it, use `===` over `==` as in the original
non-`async`/`await` version.

Author: michaelklishin

javascript-nodejs/src/emit_log_topic.js

@@ -15,7 +15,7 @@ async function main() {
         durable: false
     });
     channel.publish(exchange, key, Buffer.from(msg));
-    console.log(" [x] Sent %s:'%s'", key, msg);
+    console.log(" [x] Sent %s: '%s'", key, msg);
 
     setTimeout(function() {
         connection.close();

javascript-nodejs/src/receive_logs_direct.js

@@ -4,7 +4,7 @@ const amqp = require('amqplib');
 
 const args = process.argv.slice(2);
 
-if (args.length == 0) {
+if (args.length === 0) {
     console.log("Usage: receive_logs_direct.js [info] [warning] [error]");
     process.exit(1);
 }
@@ -24,9 +24,9 @@ async function main() {
     });
     console.log(' [*] Waiting for logs. To exit press CTRL+C');
 
-    args.forEach(function(severity) {
-        channel.bindQueue(q.queue, exchange, severity);
-    });
+    for (const severity of args) {
+        await channel.bindQueue(q.queue, exchange, severity);
+    }
 
     channel.consume(q.queue, function(msg) {
         console.log(" [x] %s: '%s'", msg.fields.routingKey, msg.content.toString());

javascript-nodejs/src/receive_logs_topic.js

@@ -4,7 +4,7 @@ const amqp = require('amqplib');
 
 const args = process.argv.slice(2);
 
-if (args.length == 0) {
+if (args.length === 0) {
     console.log("Usage: receive_logs_topic.js <facility>.<severity>");
     process.exit(1);
 }
@@ -24,9 +24,9 @@ async function main() {
     });
     console.log(' [*] Waiting for logs. To exit press CTRL+C');
 
-    args.forEach(function(key) {
-        channel.bindQueue(q.queue, exchange, key);
-    });
+    for (const key of args) {
+        await channel.bindQueue(q.queue, exchange, key);
+    }
 
     channel.consume(q.queue, function(msg) {
         console.log(" [x] %s:'%s'", msg.fields.routingKey, msg.content.toString());

javascript-nodejs/src/rpc_client.js

@@ -4,7 +4,7 @@ const amqp = require('amqplib');
 
 const args = process.argv.slice(2);
 
-if (args.length == 0) {
+if (args.length === 0) {
     console.log("Usage: rpc_client.js num");
     process.exit(1);
 }
@@ -20,7 +20,7 @@ async function main() {
 
     // Consume from the Direct Reply-to pseudo-queue (noAck is mandatory)
     channel.consume('amq.rabbitmq.reply-to', function(msg) {
-        if (msg.properties.correlationId == correlationId) {
+        if (msg.properties.correlationId === correlationId) {
             console.log(' [.] Got %s', msg.content.toString());
             setTimeout(function() {
                 connection.close();

javascript-nodejs/src/rpc_server.js

@@ -31,7 +31,7 @@ async function main() {
 }
 
 function fibonacci(n) {
-    if (n == 0 || n == 1)
+    if (n === 0 || n === 1)
         return n;
     else
         return fibonacci(n - 1) + fibonacci(n - 2);