This commit is contained in:
shoopea 2019-06-28 14:14:54 +08:00
parent 57fcd3fe73
commit 8f17c0e0c0

View File

@ -353,7 +353,7 @@ func MQKeepAliveWorker() {
err = s.Open()
}
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{}
err = json.Unmarshal(d.Body, &x)
logOnError(err, "MQKeepAliveWorker : Can't unmarshal.\n"+string(d.Body))