开启事件推送

panlei

2019-10-28 a2f3b209b491e3d573b8564aa11db6e183a259a7

开启事件推送

 main.go

@@ -7,6 +7,7 @@
    "net/http"
    _ "net/http/pprof"
    "ruleprocess/insertdata"
    "ruleprocess/labelFilter"
    "ruleprocess/structure"
    "ruleprocess/util"
    "time"
@@ -106,7 +107,7 @@
                    insertdata.InsertToEs(resultMsg)
                    logger.Debug("插入完Es所用时间：", time.Since(start))
                    //事件推送
                    //go labelFilter.Judge(resultMsg)
                    go labelFilter.Judge(resultMsg)
                //}(msg)
            }
        }