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

Revert "test"

Browse Source 
This reverts commit 81347ee093.
This commit is contained in:
shoopea 2019-06-28 15:55:39 +08:00
parent 75cc1df4d1
commit af020e8452
1 changed files with 10 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
workers.go
View File

@ -363,18 +363,16 @@ func MQKeepAliveWorker() {
time.Sleep(15 * time.Second) time.Sleep(15 * time.Second)
err = s.Open() err = s.Open()
} }
/* m, err := s.MQChannel.Consume(
m, err := s.MQChannel.Consume( s.MQQueue.Name, // queue
s.MQQueue.Name, // queue "", // consumer
"", // consumer true, // auto-ack
true, // auto-ack false, // exclusive
false, // exclusive false, // no-local
false, // no-local false, // no-wait
false, // no-wait nil, // args
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)