Update the pushRaw() method to enforce the MessageGroupId and MessageDeduplicationId values sent to AWS are strings.

patrickcarlohickman · patrickcarlohickman · commit b837609feef8 · 2024-09-21T17:00:20.000-04:00
diff --git a/src/SqsFifoQueue.php b/src/SqsFifoQueue.php
@@ -99,11 +99,11 @@ public function setSqs(SqsClient $sqs)
     public function pushRaw($payload, $queue = null, array $options = [])
     {
         $message = [
-            'QueueUrl' => $this->getQueue($queue), 'MessageBody' => $payload, 'MessageGroupId' => $this->getMeta($payload, 'group', $this->group),
+            'QueueUrl' => $this->getQueue($queue), 'MessageBody' => $payload, 'MessageGroupId' => strval($this->getMeta($payload, 'group', $this->group)),
         ];
 
         if (($deduplication = $this->getDeduplicationId($payload, $queue)) !== false) {
-            $message['MessageDeduplicationId'] = $deduplication;
+            $message['MessageDeduplicationId'] = strval($deduplication);
         }
 
         $response = $this->sqs->sendMessage($message);

Original file line number	Diff line number	Diff line change
`@@ -99,11 +99,11 @@ public function setSqs(SqsClient $sqs)`
`99`	`99`	`public function pushRaw($payload, $queue = null, array $options = [])`
`100`	`100`	`{`
`101`	`101`	`$message = [`
`102`		`- 'QueueUrl' => $this->getQueue($queue), 'MessageBody' => $payload, 'MessageGroupId' => $this->getMeta($payload, 'group', $this->group),`
	`102`	`+ 'QueueUrl' => $this->getQueue($queue), 'MessageBody' => $payload, 'MessageGroupId' => strval($this->getMeta($payload, 'group', $this->group)),`
`103`	`103`	`];`
`104`	`104`
`105`	`105`	`if (($deduplication = $this->getDeduplicationId($payload, $queue)) !== false) {`
`106`		`- $message['MessageDeduplicationId'] = $deduplication;`
	`106`	`+ $message['MessageDeduplicationId'] = strval($deduplication);`
`107`	`107`	`}`
`108`	`108`
`109`	`109`	`$response = $this->sqs->sendMessage($message);`