diff --git a/workers.go b/workers.go index ed25e8b..7063bea 100644 --- a/workers.go +++ b/workers.go @@ -139,15 +139,6 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) { } func SQLJobWorker(id int) { - // var tick time.Time - var ( - objId int64 - priority int32 - status int32 - payload string - j []Job - ) - log.Printf("SQLJobWorker[" + strconv.Itoa(id) + "] : Starting.") for true { jobs, err := loadCurrentJobs()