Commit ec879a10 authored by project's avatar project

--no commit message

--no commit message
parent 75b3f5b9
...@@ -23,7 +23,7 @@ RPCServer.prototype.start = function(cb) ...@@ -23,7 +23,7 @@ RPCServer.prototype.start = function(cb)
ch.assertQueue(q, {durable: false}); ch.assertQueue(q, {durable: false});
ch.prefetch(1); ch.prefetch(1);
console.log(' [x] Awaiting RPC requests'); //console.log(' [x] Awaiting RPC requests');
ch.consume(q, function reply(msg) { ch.consume(q, function reply(msg) {
var req = JSON.parse(msg.content.toString()); var req = JSON.parse(msg.content.toString());
......
...@@ -18,3 +18,13 @@ server.set_remote_function(function(req,callback){ ...@@ -18,3 +18,13 @@ server.set_remote_function(function(req,callback){
server.start(function(err){ server.start(function(err){
console.log('server start'); console.log('server start');
}) })
var http = require('http');
http.createServer(function (req, res) {
res.writeHead(200, {
'Content-Type': 'text/plain; charset=UTF-8'
});
res.end('Hello from node-bigstream.\n');
}).listen(9080, "");
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