This commit is contained in:
shoopea 2019-05-16 10:07:25 +08:00
parent 63cef6ee15
commit d4088edc1a

View File

@ -46,7 +46,7 @@ var (
ownUserID32 = int32(0)
lastOwnTDMsg time.Time
MQCWMsgQueue chan ChatWarsMessage
MQTDCmdQueue chan TDCommand
MQTGCmdQueue chan TGCommand
)
func main() {
@ -127,15 +127,15 @@ func main() {
return
}
MQTDCmdQueue = make(chan TDCommand, 100)
MQTGCmdQueue = make(chan TGCommand, 100)
for w := 1; w <= 3; w++ {
go MQReceiveMsgWorker(w, MQTDCmdQueue)
go MQReceiveMsgWorker(w, MQTGCmdQueue)
}
lastOwnTDMsg = time.Now()
go ListenCW(client)
go ListenMQ(client, MQTDCmdQueue)
go ListenMQ(client, MQTGCmdQueue)
go ListenMe(client)
fmt.Println("Started !")