@@ -81,7 +81,7 @@ |
||
| 81 | 81 | public function registerDeduplicators() |
| 82 | 82 | { |
| 83 | 83 | foreach (['Unique', 'Content', 'Sqs'] as $deduplicator) { |
| 84 | - $this->{"register{$deduplicator}Deduplicator"}(); |
|
| 84 | + $this->{"register{$deduplicator}deduplicator"}(); |
|
| 85 | 85 | } |
| 86 | 86 | } |
| 87 | 87 | |
@@ -32,7 +32,7 @@ |
||
| 32 | 32 | |
| 33 | 33 | $group = Arr::pull($config, 'group', 'default'); |
| 34 | 34 | $deduplicator = Arr::pull($config, 'deduplicator', 'unique'); |
| 35 | - $allowDelay = (bool)Arr::pull($config, 'allow_delay', false); |
|
| 35 | + $allowDelay = (bool) Arr::pull($config, 'allow_delay', false); |
|
| 36 | 36 | |
| 37 | 37 | return new SqsFifoQueue( |
| 38 | 38 | new SqsClient($config), |