Commit 7d3fd30a authored by project's avatar project

--no commit message

--no commit message
parent 020611b5
var redis = require('redis'); var redis = require('redis');
const PREFIX = 'bs:jobs'; const PREFIX = 'bs:regis:jobs';
module.exports.create = function(cfg) module.exports.create = function(cfg)
{ {
......
...@@ -3,13 +3,16 @@ var amqp_cfg = ctx.config.amqp; ...@@ -3,13 +3,16 @@ var amqp_cfg = ctx.config.amqp;
var QueueCaller = ctx.getLib('lib/amqp/queuecaller'); var QueueCaller = ctx.getLib('lib/amqp/queuecaller');
var qc = new QueueCaller({'url':'amqp://bigmaster.igridproject.info','name':'bs_jobs_queue'}); var amp = 'amqp://lab1.igridproject.info';
var qc = new QueueCaller({'url':amp,'name':'bs_jobs_queue'});
var cmd = { var cmd = {
'object_type':'job_execute', 'object_type':'job_execute',
'source' : 'http_listener', 'source' : 'http_listener',
'jobId' : 'job03', 'jobId' : 'job01',
'option' : {}, 'option' : {},
'input_data' : { 'input_data' : {
'type' : 'bsdata', 'type' : 'bsdata',
...@@ -22,3 +25,7 @@ var cmd = { ...@@ -22,3 +25,7 @@ var cmd = {
qc.send(cmd); qc.send(cmd);
setTimeout(function(){
qc.close()
},500)
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