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

test

Browse Source
This commit is contained in:
shoopea 2019-06-28 16:29:24 +08:00
parent 7a7e564029
commit 622a700178
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
workers.go
View File

@ -17,13 +17,12 @@ func MQGetMsgWorker(id int, msgs chan<- ChatWarsMessage) {
//log.Printf("MQGetMsgWorker[" + strconv.Itoa(id) + "] : Starting.") //log.Printf("MQGetMsgWorker[" + strconv.Itoa(id) + "] : Starting.")
var x ChatWarsMessage var x ChatWarsMessage
for true { for true {
c := MQClient{ c := new(MQClient)
User: cfg.Rabbit.User, c.User = cfg.Rabbit.User
Password: cfg.Rabbit.Password, c.Password = cfg.Rabbit.Password
Host: cfg.Rabbit.Host, c.Host = cfg.Rabbit.Host
Path: cfg.Rabbit.Path, c.Path = cfg.Rabbit.Path
SSL: false, c.SSL = false
}
err := c.Open() err := c.Open()