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 14:41:11 +08:00
parent 6b7cb32bbc
commit 81347ee093
1 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
workers.go
View File

@ -363,16 +363,18 @@ func MQKeepAliveWorker() {
time.Sleep(15 * time.Second) time.Sleep(15 * time.Second)
err = s.Open() err = s.Open()
} }
m, err := s.MQChannel.Consume( /*
s.MQQueue.Name, // queue m, err := s.MQChannel.Consume(
"", // consumer s.MQQueue.Name, // queue
true, // auto-ack "", // consumer
false, // exclusive true, // auto-ack
false, // no-local false, // exclusive
false, // no-wait false, // no-local
nil, // args false, // no-wait
) nil, // args
for d := range m { )
*/
for d := range s.MQDelivery {
log.Printf("MQKeepAliveWorker : Received a message: %s", string(d.Body)) log.Printf("MQKeepAliveWorker : Received a message: %s", string(d.Body))
x := MQKeepAlive{} x := MQKeepAlive{}
err = json.Unmarshal(d.Body, &x) err = json.Unmarshal(d.Body, &x)