Commit 6a39c5f5 authored by Kamron Aroonrua's avatar Kamron Aroonrua 💬

http resp

parent 7fd78867
...@@ -26,7 +26,7 @@ function HTTPListener(cfg) ...@@ -26,7 +26,7 @@ function HTTPListener(cfg)
this.httpacl = HttpACL.create({'conn':this.config.memstore.url}); this.httpacl = HttpACL.create({'conn':this.config.memstore.url});
this.jobcaller = new QueueCaller({'url':this.config.amqp.url,'name':'bs_jobs_cmd'}); this.jobcaller = new QueueCaller({'url':this.config.amqp.url,'name':'bs_jobs_cmd'});
this.evs = new EvenSub({'url':this.config.amqp.url,'name':'bs_trigger_cmd'}); this.evs = new EvenSub({'url':this.config.amqp.url,'name':'bs_trigger_cmd'});
//this.evp = new EvenPub({'url':this.config.amqp.url,'name':JOBCHANEL}); this.msgrecv = new EvenSub({'url':this.config.amqp.url,'name':'bs_msg_bus'});
} }
HTTPListener.prototype.start = function() HTTPListener.prototype.start = function()
...@@ -61,13 +61,13 @@ HTTPListener.prototype._http_start = function() ...@@ -61,13 +61,13 @@ HTTPListener.prototype._http_start = function()
var context = require('./lib/http-context'); var context = require('./lib/http-context');
app.use(context.middleware({ app.use(context.middleware({
'httpacl' : self.httpacl, 'httpacl' : self.httpacl,
'jobcaller' : self.jobcaller 'jobcaller' : self.jobcaller,
'msgrecv' : self.msgrecv
})); }));
app.use(require('./ws')); app.use(require('./ws'));
app.listen(API_PORT, function () { app.listen(API_PORT, function () {
console.log('WWW:HTTP START\t\t[OK]'); console.log('WWW:HTTP START\t\t[OK]');
}); });
......
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