Merge pull request #66 from foodora/sqs-message-id-getter

Add MessageID getter to Message struct
deliveryhero · Jul 16, 2019 · 0aa606e · 0aa606e
2 parents 2b6f1bd + 529bc71
commit 0aa606e
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/pubsub/awssub/sub.go b/pubsub/awssub/sub.go
@@ -151,6 +151,14 @@ func (m *subscriberMessage) String() string {
 	return msgBody
 }
 
+// returns original sqs message id
+func (m *subscriberMessage) GetMessageId() string {
+	if m.message.MessageId == nil {
+		return ""
+	}
+	return *m.message.MessageId
+}
+
 // ExtendDoneDeadline changes the visibility timeout of the underlying SQS
 // message. It will set the visibility timeout of the message to the given
 // duration.

diff --git a/pubsub/pubsub.go b/pubsub/pubsub.go
@@ -26,4 +26,5 @@ type Message interface {
 	String() string
 	ExtendDoneDeadline(time.Duration) error
 	Done() error
+	GetMessageId() string
 }