This commit is contained in:
shoopea 2019-05-17 16:10:14 +08:00
parent 4d6ebb6500
commit 05f7aa05f2
2 changed files with 4 additions and 4 deletions

2
def.go
View File

@ -16,7 +16,7 @@ type MQKeepAlive struct {
}
type MQClient struct {
Connnection *amqp.Connection
Connection *amqp.Connection
Channel *amqp.Channel
Queue amqp.Queue
}

View File

@ -109,7 +109,7 @@ func main() {
SQLMsgIdentifyQueue = make(chan int64, 100)
TGCmdQueue = make(chan TGCommand, 100)
MQTGCmdQueue = make(chan TGCommand, 100)
clientsQueue = make(map[int64]*MQQueue)
clientsQueue = make(map[int64]*MQClient)
clientsKeepAlive = make(map[int64]*MQKeepAlive)
for w := 1; w <= MQGetMsgWorkers; w++ {