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): Fix panic recovery in consumer.go

Browse Source
This commit is contained in:
Eddy Santos 2024-06-27 17:25:06 -03:00
parent bdd54501c2
commit c35190e6b1
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
amqp/consumer.go
View File

@ -517,8 +517,15 @@ func (c *consumer) doConsume() error {
c.wg.Add(1) c.wg.Add(1)
go func(msg amqplib.Delivery) { go func(msg amqplib.Delivery) {
c.dispatch(msg) defer func() {
if r := recover(); r != nil {
log.WithFields(logrus.Fields{
"error": r,
}).Error("Recovered from panic.")
}
c.wg.Done() c.wg.Done()
}()
c.dispatch(msg)
}(m) }(m)
} }