~jinersong/ruleprocess.git

派生自 ruleprocess

parent: 5c5433ce | 补丁 | 提交 | ignore whitespace

panlei

2019-10-25 f36485a662f13e030c9d7cb113c6f56f24f722d6

事件推送模块儿加异常处理

2个文件已修改

	labelFilter/req.go	2 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	labelFilter/ruleForLabel.go	5 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史

 labelFilter/req.go

@@ -85,7 +85,7 @@
    if msg, err = sock.Recv(); err != nil {
        Die("接收响应失败: %s", err.Error())
    }
    logger.Debug("数据推送成功！收到响应",string(msg))
    logger.Debug("事件推送成功！收到响应",string(msg))
    sock.Close()
}


 labelFilter/ruleForLabel.go

@@ -11,6 +11,11 @@
)

func Judge(msg structure.ResultMsg) {
    defer func() {
        if err := recover(); err != nil {
            logger.Error("事件推送模块儿的异常捕获：",err)
        }
    }()
    // 装配成自己可以识别的数据
    label := new(Label)
    label.DataFormatToLabel(msg)

			@@ -85,7 +85,7 @@
			if msg, err = sock.Recv(); err != nil {
			Die("接收响应失败: %s", err.Error())
			}
			logger.Debug("数据推送成功！收到响应",string(msg))
			logger.Debug("事件推送成功！收到响应",string(msg))
			sock.Close()
			}

			@@ -11,6 +11,11 @@
			)

			func Judge(msg structure.ResultMsg) {
			defer func() {
			if err := recover(); err != nil {
			logger.Error("事件推送模块儿的异常捕获：",err)
			}
			}()
			// 装配成自己可以识别的数据
			label := new(Label)
			label.DataFormatToLabel(msg)