Skip to content
This repository has been archived by the owner on Jun 26, 2023. It is now read-only.

Commit

Permalink
log CorrelationId on message sent in debug mode (#329)
Browse files Browse the repository at this point in the history
  • Loading branch information
jbygdell authored Feb 2, 2023
2 parents 742f98f + 6968a58 commit 87a7057
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion messenger.go
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,7 @@ func (m *AMQPMessenger) SendMessage(message Event) error {
if !confirmed.Ack {
return fmt.Errorf("failed delivery of delivery tag: %d", confirmed.DeliveryTag)
}
log.Debugf("confirmed delivery with delivery tag: %d", confirmed.DeliveryTag)
log.Debugf("Delivered message: %v, with correlation-ID: %v", string(body), corrID.String())

return nil

Expand Down

0 comments on commit 87a7057

Please sign in to comment.