test
This commit is contained in:
parent
4fe2eb5b37
commit
c79a99313d
2
mq.go
2
mq.go
@ -42,11 +42,9 @@ func MQSendMsgWorker(id int, msgs <-chan ChatWarsMessage) {
|
|||||||
ContentType: "application/json",
|
ContentType: "application/json",
|
||||||
Body: []byte(b),
|
Body: []byte(b),
|
||||||
})
|
})
|
||||||
if err != nil {
|
|
||||||
logOnError(err, "MQSendMsgWorker["+strconv.Itoa(id)+"] : Publishing message.")
|
logOnError(err, "MQSendMsgWorker["+strconv.Itoa(id)+"] : Publishing message.")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
log.Printf("MQSendMsgWorker[" + strconv.Itoa(id) + "] : Closing.")
|
log.Printf("MQSendMsgWorker[" + strconv.Itoa(id) + "] : Closing.")
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user