This commit is contained in:
shoopea 2019-05-06 11:37:51 +08:00
parent 52029dac8a
commit 27cad2827c

2
mq.go
View File

@ -28,8 +28,6 @@ func MQSendMsgWorker(id int, msgs <-chan ChatWarsMessage) {
failOnError(err, "MQSendMsgWorker["+strconv.Itoa(id)+"] : Failed to declare a queue") failOnError(err, "MQSendMsgWorker["+strconv.Itoa(id)+"] : Failed to declare a queue")
for m := range msgs { for m := range msgs {
log.Printf("MQSendMsgWorker[" + strconv.Itoa(id) + "] : Sending a message.")
b, err := json.Marshal(m) b, err := json.Marshal(m)
if err != nil { if err != nil {
logOnError(err, "MQSendMsgWorker["+strconv.Itoa(id)+"] : Marshaling message.") logOnError(err, "MQSendMsgWorker["+strconv.Itoa(id)+"] : Marshaling message.")