@@ -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 |
@@ -33,7 +33,7 @@ discard block |
||
33 | 33 | // Pull the custom config options out of the config array sent to SqsClient. |
34 | 34 | $group = Arr::pull($config, 'group', 'default'); |
35 | 35 | $deduplicator = Arr::pull($config, 'deduplicator', 'unique'); |
36 | - $allowDelay = (bool)Arr::pull($config, 'allow_delay', false); |
|
36 | + $allowDelay = (bool) Arr::pull($config, 'allow_delay', false); |
|
37 | 37 | |
38 | 38 | return new SqsFifoQueue( |
39 | 39 | new SqsClient( |
@@ -42,7 +42,7 @@ discard block |
||
42 | 42 | $config['queue'], |
43 | 43 | $config['prefix'] ?? '', |
44 | 44 | $config['suffix'] ?? '', |
45 | - (bool)($config['after_commit'] ?? null), |
|
45 | + (bool) ($config['after_commit'] ?? null), |
|
46 | 46 | $group, |
47 | 47 | $deduplicator, |
48 | 48 | $allowDelay |