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

third callbacks review

Browse Source
This commit is contained in:
shoopea 2019-08-17 14:46:14 +08:00
parent 5b9f48cae5
commit b56aabcc7e
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

@ -471,8 +471,8 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
muxCallbacks.Lock() muxCallbacks.Lock()
if mc1, mok1 := callbacks[m.TGUserID64]; mok1 { if mc1, mok1 := callbacks[m.TGUserID64]; mok1 {
if mc2, mok2 := mc1[msgParsingRules[i].MsgTypeID]; mok2 { if mc2, mok2 := mc1[msgParsingRules[i].MsgTypeID]; mok2 {
for jobID64 := range mc2 { for j := range mc2 {
err := rescheduleJob(jobID64, objJobStatusNew, time.Now().UTC()) err := rescheduleJob(mc2[j], objJobStatusNew, time.Now().UTC())
logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : callbacks triggering") logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : callbacks triggering")
} }
mc1[msgParsingRules[i].MsgTypeID] = nil mc1[msgParsingRules[i].MsgTypeID] = nil