From caaf63aaac325cd86f639f26bff91c4cccf115c7 Mon Sep 17 00:00:00 2001 From: shoopea Date: Thu, 16 May 2019 20:44:59 +0800 Subject: [PATCH] test --- main.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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)