panlei
2019-11-30 9c255c93df55e635ecb06535e129efdc72afadaf
labelFilter/ruleForLabel.go
@@ -3,7 +3,7 @@
import (
   "basic.com/dbapi.git"
   "basic.com/pubsub/protomsg.git"
   "basic.com/valib/logger.git"
   logger "github.com/jeanphorn/log4go"
   "github.com/golang/protobuf/proto"
   "github.com/knetic/govaluate"
   "ruleprocess/structure"
@@ -321,16 +321,14 @@
// 调用目标服务器的插入接口
func pushData(urls []*protomsg.PushUrl, data structure.ResultMsg) {
   for _, url := range urls {
      logger.Debug("看看推送地址:",url.Url)
      logger.Debug("推送地址:",url.Url)
      bytes,err1 := proto.Marshal(data)
      if err1 != nil {
         logger.Info("序列化失败:",err1)
      }
      if _, ok := urlPool[url.Url] ; ok {
         urlPool[url.Url] <- bytes
         logger.Info("chan信息而: ", urlPool[url.Url])
      }
      logger.Info("chan信息以: ", urlPool[url.Url])
   }