Merge pull request #131 from BrandonShutter/patch-1

michaelklishin · web-flow · commit d955055a3185 · 2017-04-27T18:48:13.000+02:00
Update rpc_client.js
diff --git a/javascript-nodejs/src/rpc_client.js b/javascript-nodejs/src/rpc_client.js
@@ -4,7 +4,7 @@ var amqp = require('amqplib/callback_api');
 
 var args = process.argv.slice(2);
 
-if (args.length == 0) {
+if (args.length === 0) {
   console.log("Usage: rpc_client.js num");
   process.exit(1);
 }
@@ -18,7 +18,7 @@ amqp.connect('amqp://localhost', function(err, conn) {
       console.log(' [x] Requesting fib(%d)', num);
 
       ch.consume(q.queue, function(msg) {
-        if (msg.properties.correlationId == corr) {
+        if (msg.properties.correlationId === corr) {
           console.log(' [.] Got %s', msg.content.toString());
           setTimeout(function() { conn.close(); process.exit(0) }, 500);
         }

Original file line number	Diff line number	Diff line change
`@@ -4,7 +4,7 @@ var amqp = require('amqplib/callback_api');`
`4`	`4`
`5`	`5`	`var args = process.argv.slice(2);`
`6`	`6`
`7`		`-if (args.length == 0) {`
	`7`	`+if (args.length === 0) {`
`8`	`8`	`console.log("Usage: rpc_client.js num");`
`9`	`9`	`process.exit(1);`
`10`	`10`	`}`
`@@ -18,7 +18,7 @@ amqp.connect('amqp://localhost', function(err, conn) {`
`18`	`18`	`console.log(' [x] Requesting fib(%d)', num);`
`19`	`19`
`20`	`20`	`ch.consume(q.queue, function(msg) {`
`21`		`- if (msg.properties.correlationId == corr) {`
	`21`	`+ if (msg.properties.correlationId === corr) {`
`22`	`22`	`console.log(' [.] Got %s', msg.content.toString());`
`23`	`23`	`setTimeout(function() { conn.close(); process.exit(0) }, 500);`
`24`	`24`	`}`