Skip to content

N
node-bigstream
Commit 1df8592f authored by project's avatar project
Browse files
Options

--no commit message 

--no commit message
parent 027e5e83
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
lib/amqp/rpcserver.js
View file @ 1df8592f
...@@ -30,10 +30,10 @@ RPCServer.prototype.start = function(cb) ...@@ -30,10 +30,10 @@ RPCServer.prototype.start = function(cb)
self.remote_function(req,function(err,resp){ self.remote_function(req,function(err,resp){
ch.sendToQueue(msg.properties.replyTo,new Buffer(JSON.stringify(resp)),{correlationId: msg.properties.correlationId}); ch.sendToQueue(msg.properties.replyTo,new Buffer(JSON.stringify(resp)),{correlationId: msg.properties.correlationId});
ch.ack(msg);
});
}); });
ch.ack(msg);
});
cb(null); cb(null);
}); });
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment