From b56aabcc7e5e42aa54230c0b1062528d6cbc9152 Mon Sep 17 00:00:00 2001 From: shoopea Date: Sat, 17 Aug 2019 14:46:14 +0800 Subject: [PATCH] third callbacks review --- workers.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/workers.go b/workers.go index b99c677..fcd535b 100644 --- a/workers.go +++ b/workers.go @@ -471,8 +471,8 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) { muxCallbacks.Lock() if mc1, mok1 := callbacks[m.TGUserID64]; mok1 { if mc2, mok2 := mc1[msgParsingRules[i].MsgTypeID]; mok2 { - for jobID64 := range mc2 { - err := rescheduleJob(jobID64, objJobStatusNew, time.Now().UTC()) + for j := range mc2 { + err := rescheduleJob(mc2[j], objJobStatusNew, time.Now().UTC()) logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : callbacks triggering") } mc1[msgParsingRules[i].MsgTypeID] = nil