This commit is contained in:
shoopea 2019-05-10 17:26:02 +08:00
parent 1e5248b605
commit a2ccadb2d4

View File

@ -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()