Skip to content

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

--no commit message 

--no commit message
parent 56eb485c
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
coreservice/scheduler.js
View file @ d5eef0e4
...@@ -20,7 +20,7 @@ function SchedulerService(cfg) ...@@ -20,7 +20,7 @@ function SchedulerService(cfg)
this.conn = ConnCtx.create(this.config); this.conn = ConnCtx.create(this.config);
this.mem = this.conn.getMemstore(); this.mem = this.conn.getMemstore();
this.jobcaller = new QueueCaller({'url':amqp_cfg.url,'name':'bs_jobs_queue'}); this.jobcaller = new QueueCaller({'url':amqp_cfg.url,'name':'bs_jobs_cmd'});
this.evs = new EvenSub({'url':amqp_cfg.url,'name':'bs_trigger_cmd'}); this.evs = new EvenSub({'url':amqp_cfg.url,'name':'bs_trigger_cmd'});
this.crons = CronList.create({'redis':this.mem}); this.crons = CronList.create({'redis':this.mem});
......
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