echo/rabbitmq-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

log request before calculating the number

Browse Source
This commit is contained in:
Giuseppe Privitera 2015-08-07 09:41:24 +01:00
parent 4078b3244d
commit 636c23b868
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
javascript-nodejs/src/rpc_server.js
View File

@ -11,10 +11,11 @@ amqp.connect('amqp://localhost', function(err, conn) {
console.log(' [x] Awaiting RPC requests');
ch.consume(q, function reply(msg) {
var n = parseInt(msg.content.toString());
var r = fibonacci(n);
console.log(" [.] fib(%d)", n);
var r = fibonacci(n);
ch.sendToQueue(msg.properties.replyTo,
new Buffer(r.toString()),
{correlationId: msg.properties.correlationId});