From 0640a70bd7c4ea696817267413e19b4a5be6dc68 Mon Sep 17 00:00:00 2001 From: Andy Cobaugh Date: Tue, 6 Sep 2022 16:14:06 -0400 Subject: [PATCH] fix(sqs): log itn event messageid correctly --- pkg/monitor/sqsevent/sqs-monitor.go | 2 +- pkg/monitor/sqsevent/sqs-monitor_test.go | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/pkg/monitor/sqsevent/sqs-monitor.go b/pkg/monitor/sqsevent/sqs-monitor.go index 5ed440a8..b2da9e98 100644 --- a/pkg/monitor/sqsevent/sqs-monitor.go +++ b/pkg/monitor/sqsevent/sqs-monitor.go @@ -241,7 +241,7 @@ func (m SQSMonitor) processInterruptionEvents(interruptionEventWrappers []Interr } if failedInterruptionEventsCount != 0 { - return fmt.Errorf("some interruption events for message Id %b could not be processed", message.MessageId) + return fmt.Errorf("some interruption events for message Id %s could not be processed", *message.MessageId) } return nil diff --git a/pkg/monitor/sqsevent/sqs-monitor_test.go b/pkg/monitor/sqsevent/sqs-monitor_test.go index 1db36a02..eae2ee25 100644 --- a/pkg/monitor/sqsevent/sqs-monitor_test.go +++ b/pkg/monitor/sqsevent/sqs-monitor_test.go @@ -918,7 +918,8 @@ func getSQSMessageFromEvent(event sqsevent.EventBridgeEvent) (sqs.Message, error return sqs.Message{}, err } eventStr := string(eventBytes) - return sqs.Message{Body: &eventStr}, nil + messageId := "d7de6634-f672-ce5c-d87e-ae0b1b5b2510" + return sqs.Message{Body: &eventStr, MessageId: &messageId}, nil } func mockIsManagedTrue(asg *h.MockedASG) h.MockedASG {