OrgGo/eventials.goevents
1
0
Fork 0
mirror of https://github.com/eventials/goevents.git synced 2025-04-24 13:48:53 +08:00
Code Issues Projects Releases Wiki Activity

fix log

Browse Source
This commit is contained in:
skrater 2017-12-19 16:01:48 -02:00
parent 6ef1633e13
commit b0b2fe3278
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
amqp/consumer.go
View File

@ -240,12 +240,6 @@ func (c *consumer) doDispatch(msg amqplib.Delivery, h *handler, retryCount int32
err := c.callAndHandlePanic(msg, h)
if err == nil {
logger.WithFields(log.Fields{
"action": h.action,
"body": msg.Body,
"message_id": msg.MessageId,
}).Error("Message handled successfully.")
if !c.autoAck {
msg.Ack(false)
}
@ -254,7 +248,7 @@ func (c *consumer) doDispatch(msg amqplib.Delivery, h *handler, retryCount int32
if retryCount >= h.maxRetries {
logger.WithFields(log.Fields{
"action": h.action,
"body": msg.Body,
"body": string(msg.Body),
"error": err,
"message_id": msg.MessageId,
}).Error("Maximum retries reached. Giving up.")
@ -265,7 +259,7 @@ func (c *consumer) doDispatch(msg amqplib.Delivery, h *handler, retryCount int32
} else {
logger.WithFields(log.Fields{
"action": h.action,
"body": msg.Body,
"body": string(msg.Body),
"error": err,
"message_id": msg.MessageId,
}).Error("Failed to process event. Retrying...")
@ -275,7 +269,7 @@ func (c *consumer) doDispatch(msg amqplib.Delivery, h *handler, retryCount int32
} else {
logger.WithFields(log.Fields{
"action": h.action,
"body": msg.Body,
"body": string(msg.Body),
"error": err,
"message_id": msg.MessageId,
}).Error("Failed to process event.")