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 {