@@ -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,14 +32,14 @@ |
||
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), |
39 | 39 | $config['queue'], |
40 | 40 | Arr::get($config, 'prefix', ''), |
41 | 41 | Arr::get($config, 'suffix', ''), |
42 | - (bool)Arr::get($config, 'after_commit', false), |
|
42 | + (bool) Arr::get($config, 'after_commit', false), |
|
43 | 43 | $group, |
44 | 44 | $deduplicator, |
45 | 45 | $allowDelay |