Update Connection.php

remove DelaySeconds parameter for FIFO queues
symfony · Sep 5, 2020 · 271a2de · 271a2de
1 parent 2288291
commit 271a2de
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/Transport/Connection.php b/Transport/Connection.php
@@ -318,6 +318,7 @@ public function send(string $body, array $headers, int $delay = 0, ?string $mess
         if (self::isFifoQueue($this->configuration['queue_name'])) {
             $parameters['MessageGroupId'] = null !== $messageGroupId ? $messageGroupId : __METHOD__;
             $parameters['MessageDeduplicationId'] = null !== $messageDeduplicationId ? $messageDeduplicationId : sha1(json_encode(['body' => $body, 'headers' => $headers]));
+            unset($parameters['DelaySeconds']);
         }
 
         $this->client->sendMessage($parameters);