From 6968a58fee0c2ee5e4426aeee1a8693774f48753 Mon Sep 17 00:00:00 2001 From: Nanjiang Shu Date: Thu, 2 Feb 2023 11:45:05 +0100 Subject: [PATCH] log CorrelationID and body of the MQ message --- messenger.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/messenger.go b/messenger.go index 856c50f..802b50f 100644 --- a/messenger.go +++ b/messenger.go @@ -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