Update the pushRaw() method to enforce the MessageGroupId and Message…

…DeduplicationId values sent to AWS are strings.
shiftonelabs · Sep 21, 2024 · b837609 · b837609
1 parent e3002f8
commit b837609
Showing 1 changed file with 2 additions and 2 deletions.
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);