Skip to content

Commit 905160e

Browse files
committed
fix: add logging
1 parent 70ccc5b commit 905160e

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

internal/consumer/rabbitmq/consumer.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -339,6 +339,7 @@ func buildMessage(consumerMeta map[string]interface{}, receivedMsg amqp.Delivery
339339
logrus.Error("failed to unmarshal the message, got err: ", err)
340340
logrus.WithFields(logrus.Fields{
341341
"consumer_meta": consumerMeta,
342+
"msg": string(receivedMsg.Body),
342343
"error": err,
343344
}).Error("failed to unmarshal the message, removing the message due to wrong message format")
344345
return msg, errors.ErrInvalidMessageFormat

0 commit comments

Comments
 (0)