|
@@ -14,9 +14,9 @@ const jsWrapperPrifixTemplate = `function %s(msgStr, metaDataStr, msgType) {
|
|
if(!metaData === undefined)
|
|
if(!metaData === undefined)
|
|
metaData = {}
|
|
metaData = {}
|
|
if(!msgStr === undefined)
|
|
if(!msgStr === undefined)
|
|
- metaData = {}
|
|
|
|
|
|
+ msgStr = {}
|
|
if(!metaDataStr === undefined)
|
|
if(!metaDataStr === undefined)
|
|
- metaData = {}
|
|
|
|
|
|
+ metaDataStr = {}
|
|
var msg = JSON.parse(msgStr);
|
|
var msg = JSON.parse(msgStr);
|
|
var metaData = JSON.parse(metaDataStr);
|
|
var metaData = JSON.parse(metaDataStr);
|
|
if(!metaData === undefined)
|
|
if(!metaData === undefined)
|
|
@@ -59,12 +59,12 @@ func (j *FilterJavascriptNode) OnMessage(ctx ruleEngine.Context, message *protoc
|
|
ctx.TellError(next, err)
|
|
ctx.TellError(next, err)
|
|
return errors.New("metadata marshal error " + err.Error())
|
|
return errors.New("metadata marshal error " + err.Error())
|
|
}
|
|
}
|
|
- fmt.Printf("metaData-------%s:", string(metaData))
|
|
|
|
res, err := j.vm.Call("filter", nil, body, string(metaData), message.Type)
|
|
res, err := j.vm.Call("filter", nil, body, string(metaData), message.Type)
|
|
if err != nil {
|
|
if err != nil {
|
|
- next := j.processError(ctx, message, err)
|
|
|
|
- ctx.TellError(next, err)
|
|
|
|
|
|
+ //next := j.processError(ctx, message, err)
|
|
|
|
+ //ctx.TellError(next, err)
|
|
server.Log.Errorf("vm call filter error:%s", err.Error())
|
|
server.Log.Errorf("vm call filter error:%s", err.Error())
|
|
|
|
+ fmt.Printf("________++++==%s", metaData)
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
v := false
|
|
v := false
|