Commit 487a83e1 authored by Kamron Aroonrua's avatar Kamron Aroonrua 💬

Merge branch 'ondev-gcs' into 'dev'

Ondev gcs

See merge request !12
parents 99761577 da79d8c6
...@@ -8,7 +8,7 @@ var async = require('async'); ...@@ -8,7 +8,7 @@ var async = require('async');
function perform_function(context,request,response){ function perform_function(context,request,response){
var job_id = context.jobconfig.job_id; var job_id = context.jobconfig.job_id;
var transaction_id = context.transaction.id; var transaction_id = context.transaction.id;
var param = context.jobconfig.data_out.param; var param = context.jobconfig.data_out.param || {};
var memstore = context.task.memstore; var memstore = context.task.memstore;
var in_type = request.type; var in_type = request.type;
...@@ -36,7 +36,7 @@ function perform_function(context,request,response){ ...@@ -36,7 +36,7 @@ function perform_function(context,request,response){
'data' : data[idx] 'data' : data[idx]
} }
var topic=Utils.vm_execute_text(ev,prm_topic); var topic=Utils.vm_execute_text(ev,prm_topic);
client.publish(topic,data[idx],function(err){ client.publish(topic,JSON.stringify(data[idx]),function(err){
idx++; idx++;
callback(err); callback(err);
}); });
......
...@@ -20,6 +20,7 @@ if(m.read=="false" && m.write=="false") ...@@ -20,6 +20,7 @@ if(m.read=="false" && m.write=="false")
if(m.read=="true"){ss.http_start();} if(m.read=="true"){ss.http_start();}
if(m.write=="true"){ if(m.write=="true"){
ss.amqp_start(); ss.amqp_start();
ss.ipc_start(); //Disable IPC Feature
//ss.ipc_start();
} }
} }
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