chtwrs/chirpnest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
shoopea 2019-05-17 15:13:48 +08:00
parent 4a16193666
commit 54022a26a8
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
main.go
View File

@ -50,7 +50,7 @@ var (
TGCmdQueue chan TGCommand TGCmdQueue chan TGCommand
MQTGCmdQueue chan TGCommand MQTGCmdQueue chan TGCommand
msgParsingRules map[int]MessageParsingRule msgParsingRules map[int]MessageParsingRule
clientsQueues map[int64]MQKeepAlive clientsQueues map[int64]*MQKeepAlive
) )
func PrintText(m *tb.Message) { func PrintText(m *tb.Message) {
@ -108,7 +108,7 @@ func main() {
SQLMsgIdentifyQueue = make(chan int64, 100) SQLMsgIdentifyQueue = make(chan int64, 100)
TGCmdQueue = make(chan TGCommand, 100) TGCmdQueue = make(chan TGCommand, 100)
MQTGCmdQueue = make(chan TGCommand, 100) MQTGCmdQueue = make(chan TGCommand, 100)
clientsQueues = make(map[int64]MQKeepAlive) clientsQueues = make(map[int64]*MQKeepAlive)
for w := 1; w <= MQGetMsgWorkers; w++ { for w := 1; w <= MQGetMsgWorkers; w++ {
go MQGetMsgWorker(w, MQCWMsgQueue) go MQGetMsgWorker(w, MQCWMsgQueue)