--no commit message

--no commit message

jobexecutor/lib/jobtask.js

+var util = require('util');
+var EventEmitter = require('events').EventEmitter;
+
+function JobTask(prm)
+{
+  EventEmitter.call(this);
+
+};
+util.inherits(JobTask, EventEmitter);
+//handle.emit('done',{'status':'error','data':err});

jobexecutor/lib/memstore.js

+var redis = require('redis');
+const PREFIX = 'bs:jobs';
+
+function memstore(conf){
+  this.prefix = PREFIX + ':' + conf.job_id + ':' + conf.cat;
+
+  if(conf.mem){
+      this.mem = conf.mem;
+  }else if(conf.conn){
+    this.mem = redis.createClient(conf.conn);
+  }
+}
+
+memstore.prototype.setItem = function(k,v,cb){
+  var key = this.prefix + ":" + k;
+  this.mem.set(key,v,cb);
+}
+
+memstore.prototype.getItem = function(k,cb)
+{
+  var key = this.prefix + ":" + k;
+  this.mem.get(key,cb);
+}
+
+module.exports = memstore;

test/test.js

@@ -102,10 +102,10 @@ const crypto = require("crypto");
 //
 // setTimeout(function() { evp.close(function(err){console.log('close');}); }, 1500);
 
-var EvenSub = ctx.getLib('lib/amqp/event-sub');
-
-var evs = new EvenSub({'url':'amqp://bigmaster.igridproject.info','name':'bs_storage'});
-
-evs.sub('storage.sds.#',function(err,msg){
-  console.log(msg);
-});
+// var EvenSub = ctx.getLib('lib/amqp/event-sub');
+//
+// var evs = new EvenSub({'url':'amqp://bigmaster.igridproject.info','name':'bs_storage'});
+//
+// evs.sub('storage.sds.#',function(err,msg){
+//   console.log(msg);
+// });