chtwrs/chirpnest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

improve debug for msg unidentified

Browse Source
This commit is contained in:
shoopea 2019-08-21 15:15:32 +08:00
parent f5e48f3353
commit e465d3fb54
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
workers.go
View File

@ -333,8 +333,8 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
//log.Printf("SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Message retrieved (%d)\n%s\n", objId, m.Text) //log.Printf("SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Message retrieved (%d)\n%s\n", objId, m.Text)
rule, err := getMsgParsingRule(m) rule, err := getMsgParsingRule(m)
if err != nil { if err != nil {
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : msgRegex.") //logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : msgRegex.")
log.Printf("SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] :\n Message unidentified (%d)\n%s\n", objId, m.Text) log.Printf("SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Message unidentified (%d)\n%s\n", objId, m.Text)
} else { } else {
err = setObjSubTypeId(objId, rule.MsgTypeID) err = setObjSubTypeId(objId, rule.MsgTypeID)
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : setObjSubTypeId") logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : setObjSubTypeId")