Skip to content

Commit 291b5ef

Browse files
author
Davide Donattini
committed
Add MessageDeduplicationId and MessageGroupId parameters to a sendMessage function
1 parent 3f98927 commit 291b5ef

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)