@@ -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 |
@@ -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 | |