@@ -10,8 +10,8 @@ |
||
10 | 10 | use EventHandlerTrait; |
11 | 11 | |
12 | 12 | /** |
13 | - * @var int the unix timestamp the job should be processed |
|
14 | - */ |
|
13 | + * @var int the unix timestamp the job should be processed |
|
14 | + */ |
|
15 | 15 | |
16 | 16 | |
17 | 17 | private $timeToSend; |
@@ -157,7 +157,7 @@ |
||
157 | 157 | protected function migrateJobs($from, $to) |
158 | 158 | { |
159 | 159 | $options = ['cas' => true, 'watch' => $from, 'retry' => 10]; |
160 | - $this->getConnection()->getInstance()->transaction($options, function ($transaction) use ($from, $to) { |
|
160 | + $this->getConnection()->getInstance()->transaction($options, function($transaction) use ($from, $to) { |
|
161 | 161 | |
162 | 162 | $time = time(); |
163 | 163 | // First we need to get all of jobs that have expired based on the current time |
@@ -10,8 +10,8 @@ |
||
10 | 10 | use EventHandlerTrait; |
11 | 11 | |
12 | 12 | /** |
13 | - * State new. |
|
14 | - */ |
|
13 | + * State new. |
|
14 | + */ |
|
15 | 15 | |
16 | 16 | |
17 | 17 | const STATE_NEW = 'N'; |
@@ -20,7 +20,7 @@ |
||
20 | 20 | |
21 | 21 | protected function defineConnectionString() |
22 | 22 | { |
23 | - if (! isset($this->configuration['dsn'])) { |
|
23 | + if (!isset($this->configuration['dsn'])) { |
|
24 | 24 | $this->configuration['dsn'] = sprintf("mysql:host=%s;dbname=%s;port=%s", $this->configuration['host'] ?? '', $this->configuration['db'] ?? '', $this->configuration['port'] ?? 3306); |
25 | 25 | } |
26 | 26 | } |
@@ -28,7 +28,7 @@ |
||
28 | 28 | */ |
29 | 29 | public function connect() |
30 | 30 | { |
31 | - if (! is_null($this->connection)) { |
|
31 | + if (!is_null($this->connection)) { |
|
32 | 32 | $this->disconnect(); |
33 | 33 | } |
34 | 34 |
@@ -12,8 +12,8 @@ |
||
12 | 12 | use EventHandlerTrait; |
13 | 13 | |
14 | 14 | /** |
15 | - * @var Mailer instance to the send the mails |
|
16 | - */ |
|
15 | + * @var Mailer instance to the send the mails |
|
16 | + */ |
|
17 | 17 | |
18 | 18 | |
19 | 19 | private $mailer; |