--no commit message

--no commit message

plugins/di/di-http-request/execute.js

 function execute_function(context,response){
-  // var job_id = context.profile.job_id;
-  // var transaction_id = context.profile.transaction_id;
-  // var param = ctx.parameter;
+  var job_id = context.jobconfig.job_id;
+  var transaction_id = context.job.transaction_id;
+  var param = context.jobconfig.data_in.param;
+  var memstore = context.job.memstore
 
   var data = 'hello world';
 
-  setTimeout(function () {
-    response.success(context.jobid + ' ' + data);
-}, 1000);
 
+  //memstore.setvalue('timestamp.xxx',ts)
 
-  //response.cancel();
+
+
+  //response.reject();
   //response.error("error message")
   //response.success(data);
 }

plugins/di/di-http-request/index.js

@@ -3,7 +3,8 @@ var DIPlugin = require('../di-plugin');
 
 function DITask(context){
   DIPlugin.call(this,context);
-  this.name = "http"
+  this.name = "http-request";
+  this.output_type = "text";
 }
 util.inherits(DITask,DIPlugin);
 

plugins/di/di-plugin.js

@@ -38,11 +38,11 @@ DIResponse.prototype.success = function(data){
 }
 
 DIResponse.prototype.error = function(err){
-  this.handle.emit('done',response('error',data));
+  this.handle.emit('done',response('error',err));
 }
 
-DIResponse.prototype.cancel = function(){
-  this.handle.emit('done',response('cancel',null));
+DIResponse.prototype.reject = function(){
+  this.handle.emit('done',response('reject',null));
 }
 
 function response(status,data){

test/testdi.js

@@ -5,4 +5,4 @@ var di = new DITask({jobid:'j01'});
 di.run();
 di.on('done',function(response){
   console.log('>> ' + response.data);
-})
+});