Skip to content

Commit 3b7044a

Browse files
authored
Merge pull request #117 from studiomado/aws-sqs-fifo-queue-support
Add support for AWS SQS new FIFO type queue
2 parents 14c05a9 + 291b5ef commit 3b7044a

1 file changed

Lines changed: 5 additions & 3 deletions

File tree

src/Provider/AwsProvider.php

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -211,9 +211,11 @@ public function publish(array $message, array $options = [])
211211
}
212212

213213
$result = $this->sqs->sendMessage([
214-
'QueueUrl' => $this->queueUrl,
215-
'MessageBody' => json_encode($message),
216-
'DelaySeconds' => $options['message_delay']
214+
'QueueUrl' => $this->queueUrl,
215+
'MessageBody' => json_encode($message),
216+
'DelaySeconds' => $options['message_delay'],
217+
'MessageDeduplicationId' => hash('sha256',json_encode($message)),
218+
'MessageGroupId' => $this->getNameWithPrefix()
217219
]);
218220

219221
$context = [

0 commit comments

Comments
 (0)