diff --git a/mq.go b/mq.go index 37fd631..716bd21 100644 --- a/mq.go +++ b/mq.go @@ -82,7 +82,7 @@ func MQReceiveMsgWorker(id int, cmd chan<- TGCommand) { failOnError(err, "MQReceiveMsgWorker["+strconv.Itoa(id)+"] : Failed to declare a consumer") for d := range m { - //log.Printf("MQReceiveMsgWorker["+strconv.Itoa(id)+"] : Received a message:\n %s", string(d.Body)) + log.Printf("MQReceiveMsgWorker["+strconv.Itoa(id)+"] : Received a message:\n %s", string(d.Body)) err = json.Unmarshal(d.Body, &c) logOnError(err, "MQReceiveMsgWorker["+strconv.Itoa(id)+"] : Can't unmarshal.\n"+string(d.Body)) if err == nil {