Make sure we can work with FIFO

README.md

@@ -8,6 +8,7 @@ This guide assumes that:
 - Symfony Messenger is installed
 - Bref is installed and [configured to deploy Symfony](https://bref.sh/docs/frameworks/symfony.html)
 - a SQS queue has already been created
+- (If FIFO queue, then enable "Content-Based Deduplication")
 
 First, install this package:
 
@@ -32,7 +33,10 @@ Next, configure Symfony Messenger to dispatch a message via SQS:
 framework:
     messenger:
         transports:
-            async: '%env(MESSENGER_TRANSPORT_DSN)%'
+            async: 
+                dsn: '%env(MESSENGER_TRANSPORT_DSN)%'
+                # If FIFO queue, you must add message_group_id. 
+                options: { message_group_id: com_example }
         routing:
              'App\Message\MyMessage': async
 ```

src/Sqs/SqsTransport.php

@@ -19,12 +19,15 @@ class SqsTransport implements TransportInterface
     private $sqs;
     /** @var string */
     private $queueUrl;
+    /** @var string|null */
+    private $messageGroupId;
 
-    public function __construct(SqsClient $sqs, ?SerializerInterface $serializer, string $queueUrl)
+    public function __construct(SqsClient $sqs, ?SerializerInterface $serializer, string $queueUrl, ?string $messageGroupId)
     {
         $this->sqs = $sqs;
         $this->serializer = $serializer ?? new PhpSerializer;
         $this->queueUrl = $queueUrl;
+        $this->messageGroupId = $messageGroupId;
     }
 
     public function send(Envelope $envelope): Envelope
@@ -43,6 +46,10 @@ public function send(Envelope $envelope): Envelope
             'QueueUrl' => $this->queueUrl,
         ];
 
+        if ($this->messageGroupId !== null) {
+            $arguments['MessageGroupId'] = $this->messageGroupId;
+        }
+
         try {
             $result = $this->sqs->sendMessage($arguments);
         } catch (Throwable $e) {

src/Sqs/SqsTransportFactory.php

@@ -22,7 +22,7 @@ public function __construct(SqsClient $sqs, ?SerializerInterface $serializer = n
 
     public function createTransport(string $dsn, array $options, SerializerInterface $serializer): TransportInterface
     {
-        return new SqsTransport($this->sqs, $this->serializer, $dsn);
+        return new SqsTransport($this->sqs, $this->serializer, $dsn, $options['message_group_id'] ?? null);
     }
 
     public function supports(string $dsn, array $options): bool