--no commit message

--no commit message

conf/config.js

 module.exports = {
-  'amqp' : require('./amqp.json')
+  'amqp' : require('./amqp.json'),
+  'memstore' : require('./memstore.json')
 }

conf/memstore.json

+{
+  "type" : "redis",
+  "url" : "redis://:lab1.igridproject.info:6380/1"
+}

lib/amqp/rpcserver.js

-var amqp = require('amqplib/callback_api');
+ var amqp = require('amqplib/callback_api');
 
 function RPCServer(config)
 {

lib/conn/connectionContext.js

+var Redis = require('ioredis');
+
+module.exports.create = function(cfg,opt)
+{
+  var conn = new ConnectionContext(cfg,opt);
+  return conn;
+}
+
+function ConnCtx(cfg,opt)
+{
+  this.config = cgf;
+}
+
+ConnCtx.prototype.getMemstore = function(opt)
+{
+  if(!this.redis){
+    this.redis = new Redis(this.config.memstore.url);
+  }
+
+  return this.redis;
+}

lib/mems/resourceStore.js

+
+function ResourceStore(prm)
+{
+
+}

package.json

@@ -19,6 +19,7 @@
     "buffalo": "^0.1.3",
     "dateformat": "^1.0.12",
     "express": "^4.14.0",
+    "ioredis": "^2.5.0",
     "node-persist": "^2.0.7",
     "node-schedule": "^1.2.0",
     "node-uuid": "^1.4.7",

test/test.js

@@ -21,26 +21,3 @@ const crypto = require("crypto");
 // const id = crypto.randomBytes(16).toString("hex");
 //
 // console.log(id);
-var cid = null;
-
-var a=0;
-var b=0;
-for(var i=0;i<1000000000;i++){
-  if(i==0){
-    a= (new Date()).getTime();
-  }else if(i=1000000000-1){
-    b=(new Date()).getTime();
-    var c = b-a;
-    console.log(c);
-  }
-  //cid = uuid.v4()
-  var aid = crypto.randomBytes(12).toString("hex");
-
-  if(aid === cid){
-    console.log('cfggg');
-
-  }
-  cid=aid;
-}
-
-console.log(cid);