Commit d6639249 authored by 谢宇轩's avatar 谢宇轩

fix(ES-Plugin): 更新逻辑

parent 241a0a12
...@@ -2,3 +2,4 @@ ...@@ -2,3 +2,4 @@
*.exe *.exe
/log /log
logtransfer.conf logtransfer.conf
./logtransfer
\ No newline at end of file
...@@ -14,7 +14,12 @@ func (saveEs *SaveES) HandleFunc(m *entity.Matedata) error { ...@@ -14,7 +14,12 @@ func (saveEs *SaveES) HandleFunc(m *entity.Matedata) error {
log.Printf("SaveES: %s", (*saveEs.params)["index"]) log.Printf("SaveES: %s", (*saveEs.params)["index"])
m.Index = fmt.Sprintf("%s", (*saveEs.params)["index"]) m.Index = fmt.Sprintf("%s", (*saveEs.params)["index"])
m.Data["topic"] = m.Topic m.Data["topic"] = m.Topic
if level, ok := m.Data["level"]; level == "" || !ok {
m.Data["level"] = m.Level m.Data["level"] = m.Level
}
if agent, ok := m.Data["level"]; agent == "" || !ok {
m.Data["agent"] = m.SourceAgent
}
entity.HandleMessage(m) entity.HandleMessage(m)
return nil return nil
} }
......
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