--no commit message

--no commit message

coreservice/lib/trigger-manager.js

@@ -33,5 +33,6 @@ TriggerManager.prototype.reload = function (prm,cb)
   }
 
   self.evp.send(topic,msg);
-  cb(null);
+
+  if(typeof cb == 'function'){cb(null);}
 }

lib/mems/job-registry.js

@@ -39,11 +39,20 @@ JobRegistry.prototype.setJob = function(jobid,job,cb)
   var self = this;
   var jobKey = PREFIX + ':' + jobid;
   var strjob = JSON.stringify(job);
-  this.mem.set(jobKey,strjob);
+  this.mem.set(jobKey,strjob,cb);
 
-  if(typeof cb == 'function'){
-    cb();
-  }
+  // if(typeof cb == 'function'){
+  //   cb();
+  // }
+
+}
+
+JobRegistry.prototype.deleteJob = function(jobid,cb)
+{
+  var self = this;
+  var jobKey = PREFIX + ':' + jobid;
+
+  this.mem.del(jobKey,cb);
 
 }
 

lib/mems/trigger-registry.js

@@ -19,17 +19,32 @@ var TR = function TriggerRegistry(cfg)
   }
 }
 
-TR.prototype.setTrigger = function(name,trigger,cb)
+TR.prototype.setTrigger = function(id,trigger,cb)
 {
   var self = this;
   var strTrigger = JSON.stringify(trigger);
-  self.mem.hset(KEYS,name,strTrigger);
+  self.mem.hset(KEYS,id,strTrigger);
 
   if(typeof cb == 'function'){
     cb();
   }
 }
 
+TR.prototype.deleteTrigger = function (id,cb)
+{
+  var self = this;
+  self.mem.hdel(KEYS,id);
+
+  if(typeof cb == 'function'){
+    cb();
+  }
+}
+
+TR.prototype.deleteByJobId = function (jobid,cb)
+{
+  
+}
+
 TR.prototype.setByJob = function(job,cb)
 {
   var self = this;