Skip to content

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

--no commit message 

--no commit message
parent d5eef0e4
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 2 deletions
jobworker/worker.js
View file @ 7dddc3cc
...@@ -45,10 +45,9 @@ JW.prototype.amqp_pmr_start = function () ...@@ -45,10 +45,9 @@ JW.prototype.amqp_pmr_start = function ()
}); });
self.amqp_server_pmr.set_execute_function(function(data,callback){ self.amqp_server_pmr.set_execute_function(function(data,callback){
console.log(data);
if(data.option && data.option.exe_level && data.option.exe_level=='secondary') if(data.option && data.option.exe_level && data.option.exe_level=='secondary')
{ {
console.log('WORKER:Forword job[' + data.jobId + '] to SJW'); console.log('WORKER:Forward job[' + data.jobId + '] to SJW');
self.QCaller.send(data); self.QCaller.send(data);
}else{ }else{
self._execute_job(data,function (err) { self._execute_job(data,function (err) {
......
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