Skip to content

Commit f85efe1

Browse files
authored
fix(sqs): log itn event messageid correctly (#684)
1 parent 10edb16 commit f85efe1

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

pkg/monitor/sqsevent/sqs-monitor.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -241,7 +241,7 @@ func (m SQSMonitor) processInterruptionEvents(interruptionEventWrappers []Interr
241241
}
242242

243243
if failedInterruptionEventsCount != 0 {
244-
return fmt.Errorf("some interruption events for message Id %b could not be processed", message.MessageId)
244+
return fmt.Errorf("some interruption events for message Id %s could not be processed", *message.MessageId)
245245
}
246246

247247
return nil

pkg/monitor/sqsevent/sqs-monitor_test.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -918,7 +918,8 @@ func getSQSMessageFromEvent(event sqsevent.EventBridgeEvent) (sqs.Message, error
918918
return sqs.Message{}, err
919919
}
920920
eventStr := string(eventBytes)
921-
return sqs.Message{Body: &eventStr}, nil
921+
messageId := "d7de6634-f672-ce5c-d87e-ae0b1b5b2510"
922+
return sqs.Message{Body: &eventStr, MessageId: &messageId}, nil
922923
}
923924

924925
func mockIsManagedTrue(asg *h.MockedASG) h.MockedASG {

0 commit comments

Comments
 (0)