diff --git a/job.go b/job.go index 0b2ce07..f9377c6 100644 --- a/job.go +++ b/job.go @@ -67,7 +67,7 @@ func createJobCallback(jobTypeID int32, userID64 int64, msgTypeID64 int64, paylo func setJobCallback(jobID64 int64, userID64 int64, msgTypeID64 int64) { muxCallbacks.Lock() if _, ok := callbacks[userID64]; !ok { - callbacks[userID64] = make(map[int64][]int) + callbacks[userID64] = make(map[int64][]int64) } s := callbacks[userID64][msgTypeID64] s = append(s, jobID64) diff --git a/workers.go b/workers.go index 93092bb..b99c677 100644 --- a/workers.go +++ b/workers.go @@ -475,7 +475,7 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) { err := rescheduleJob(jobID64, objJobStatusNew, time.Now().UTC()) logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : callbacks triggering") } - mc1[msgParsingRules[i].MsgTypeID] = make([]int64) + mc1[msgParsingRules[i].MsgTypeID] = nil } } muxCallbacks.Unlock()