fix(sqs): log itn event messageid correctly

aws · Sep 6, 2022 · 0640a70 · 0640a70
1 parent 10edb16
commit 0640a70
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git 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
@@ -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 {