mirror of
https://github.com/eventials/goevents.git
synced 2025-04-28 13:48:49 +08:00
(feat): Add topic and data to error log in publish message
This commit is contained in:
parent
bdd54501c2
commit
0c4f095589
@ -124,6 +124,8 @@ func (p *producer) drainInternalQueue() {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
logrus.WithFields(logrus.Fields{
|
logrus.WithFields(logrus.Fields{
|
||||||
"message": m,
|
"message": m,
|
||||||
|
"topic": m.action,
|
||||||
|
"data": string(m.data),
|
||||||
"error": err,
|
"error": err,
|
||||||
}).Error("Failed to publish message.")
|
}).Error("Failed to publish message.")
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user