inject messageId to the sqsMessage

Benoît Lévêque · Benoît Lévêque · commit e6aa278f9723 · 2020-01-07T11:31:46.000+01:00
diff --git a/pkg/sqs/SqsConsumer.php b/pkg/sqs/SqsConsumer.php
@@ -185,6 +185,10 @@ protected function convertMessage(array $sqsMessage): SqsMessage
     {
         $message = $this->context->createMessage();
 
+        if (isset($sqsMessage['MessageId'])) {
+            $message->setMessageId($sqsMessage['MessageId']);
+        }
+
         $message->setBody($sqsMessage['Body']);
         $message->setReceiptHandle($sqsMessage['ReceiptHandle']);
 

Original file line number	Diff line number	Diff line change
`@@ -185,6 +185,10 @@ protected function convertMessage(array $sqsMessage): SqsMessage`
`185`	`185`	`{`
`186`	`186`	`$message = $this->context->createMessage();`
`187`	`187`
	`188`	`+ if (isset($sqsMessage['MessageId'])) {`
	`189`	`+ $message->setMessageId($sqsMessage['MessageId']);`
	`190`	`+ }`
	`191`	`+`
`188`	`192`	`$message->setBody($sqsMessage['Body']);`
`189`	`193`	`$message->setReceiptHandle($sqsMessage['ReceiptHandle']);`
`190`	`194`