diff --git a/main.go b/main.go
index de6b4d6..d31ed07 100644
--- a/main.go
+++ b/main.go
@@ -112,7 +112,7 @@ func main() {
 		go MQGetMsgWorker(w, MQCWMsgQueue)
 	}
 	for w := 1; w <= SQLCWMsgWorkers; w++ {
-		go SQLCWMsgWorker(w, MQCWIncMsgQueue, SQLMsgIdentifyQueue)
+		go SQLCWMsgWorker(w, MQCWMsgQueue, SQLMsgIdentifyQueue)
 	}
 	for w := 1; w <= SQLIdentifyMsgWorkers; w++ {
 		go SQLIdentifyMsgWorker(w, SQLMsgIdentifyQueue)