From fab9d3da73ddd6023d274e5b23f69afb32a13e7b Mon Sep 17 00:00:00 2001
From: shoopea <shoopea@siteop.biz>
Date: Sat, 25 May 2019 20:23:15 +0800
Subject: [PATCH] testtest

---
 sql.go     | 2 +-
 workers.go | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/sql.go b/sql.go
index ca0b537..2b2fe4d 100644
--- a/sql.go
+++ b/sql.go
@@ -1623,7 +1623,7 @@ func loadMsgParsingRules() (m map[int]MessageParsingRule, err error) {
 	return m, nil
 }
 
-func loadCurrentJobs(sid int64) ([]Job, error) {
+func loadCurrentJobs(sid int) ([]Job, error) {
 	var (
 		objId     int64
 		jobTypeId int32
diff --git a/workers.go b/workers.go
index 3925e44..a4c03f4 100644
--- a/workers.go
+++ b/workers.go
@@ -258,7 +258,7 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
 func SQLJobWorker(id int) {
 	//log.Printf("SQLJobWorker[" + strconv.Itoa(id) + "] : Starting.")
 	for true {
-		jobs, err := loadCurrentJobs()
+		jobs, err := loadCurrentJobs(id)
 		logOnError(err, "SQLJobWorker["+strconv.Itoa(id)+"] : loadCurrentJobs")
 		if len(jobs) > 0 {
 			log.Printf("SQLJobWorker["+strconv.Itoa(id)+"] : %d jobs.\n", len(jobs))