diff --git a/def.go b/def.go index f60cf46..559399a 100644 --- a/def.go +++ b/def.go @@ -324,7 +324,8 @@ const ( SQLIdentifyMsgWorkers = 6 SQLMsgIdentifyQueueSize = 100 SQLMsgRescanJobSize = 25 - SQLJobWorkers = 12 + JobWorkers = 12 + JobQueueSize = 100 TGCmdWorkers = 3 TGCmdQueueSize = 100 MQTGCmdWorkers = 3 diff --git a/job.go b/job.go index c17f66e..980164c 100644 --- a/job.go +++ b/job.go @@ -316,7 +316,7 @@ func jobPillage(j Job) { s := TGCommand{ Type: commandSendMsg, - Text: fmt.Sprintf("No outcome for the pillage yet(%s)", m.Date.Format(time.RFC3339)), + Text: fmt.Sprintf("No outcome for the pillage yet"), ToUserID64: j.UserID64, } TGCmdQueue <- s diff --git a/main.go b/main.go index c980a4c..df41d82 100644 --- a/main.go +++ b/main.go @@ -139,8 +139,8 @@ func main() { for w := 1; w <= SQLIdentifyMsgWorkers; w++ { go SQLIdentifyMsgWorker(w, SQLMsgIdentifyQueue) } - for w := 1; w <= jobWorkers; w++ { - go jobWorker(w, JobQueue) + for w := 1; w <= JobWorkers; w++ { + go JobWorker(w, JobQueue) } for w := 1; w <= TGCmdWorkers; w++ { go TGCmdWorker(w, b, TGCmdQueue) diff --git a/workers.go b/workers.go index 9c49198..6cbb28c 100644 --- a/workers.go +++ b/workers.go @@ -297,7 +297,7 @@ func SQLJobWorker() { log.Printf("SQLJobWorker : Closing.") } -func jobWorker(id int, jobs <-chan Job) { +func JobWorker(id int, jobs <-chan Job) { //log.Printf("jobWorker[" + strconv.Itoa(id) + "] : Starting.") for j := range jobs { switch j.JobTypeID {