Skip to content

Commit e516350

Browse files
committed
fix review issues
1 parent 7261706 commit e516350

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

CHANGELOG.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,7 @@ Yii2 Queue Extension Change Log
1010
- Bug #267: Fixed symfony/process incompatibility (rob006)
1111
- Enh: Job execution result that forwarded to the event handler (zhuravljov)
1212
- Enh: ErrorEvent mark as deprecated (zhuravljov)
13+
- Enh: Add AWS SQS FIFO support (kringkaste)
1314

1415
2.1.0 May 24, 2018
1516
------------------

docs/guide/driver-sqs.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ return [
4646

4747
The message group ID is required by SQS for FIFO queues. You can configure your own or use the "default" value.
4848

49-
The deduplication ID is generated automatically, so no matter if you have activated content based deduplication in the SQS queue or not, this ID will be used.
49+
The deduplication ID is generated automatically, so no matter if you have activated content-based deduplication in the SQS queue or not, this ID will be used.
5050

5151
Console
5252
-------

src/drivers/sqs/Queue.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -189,12 +189,12 @@ protected function pushMessage($message, $ttr, $delay, $priority)
189189
],
190190
];
191191

192-
if (substr($this->url,-5) === '.fifo') {
192+
if (substr($this->url, -5) === '.fifo') {
193193
$request['MessageGroupId'] = $this->messageGroupId;
194194
$request['MessageDeduplicationId'] = hash('sha256', $message);
195195
}
196196

197-
$response = $this->getClient()->sendMessage();
197+
$response = $this->getClient()->sendMessage($request);
198198
return $response['MessageId'];
199199
}
200200

0 commit comments

Comments
 (0)