@@ -108,7 +108,9 @@ |
||
| 108 | 108 | string $queueName, |
| 109 | 109 | int $sleepSeconds = 3 |
| 110 | 110 | ) { |
| 111 | - if ($sleepSeconds < 1) $sleepSeconds = 1; |
|
| 111 | + if ($sleepSeconds < 1) { |
|
| 112 | + $sleepSeconds = 1; |
|
| 113 | + } |
|
| 112 | 114 | |
| 113 | 115 | $this->loopConnection(function () use ($sleepSeconds, $queueName) { |
| 114 | 116 | |
@@ -113,7 +113,9 @@ |
||
| 113 | 113 | string $queueName, |
| 114 | 114 | int $sleepSeconds = 3 |
| 115 | 115 | ) { |
| 116 | - if ($sleepSeconds < 1) $sleepSeconds = 1; |
|
| 116 | + if ($sleepSeconds < 1) { |
|
| 117 | + $sleepSeconds = 1; |
|
| 118 | + } |
|
| 117 | 119 | |
| 118 | 120 | if (empty($this->onExecutingCallback)) { |
| 119 | 121 | throw new \Exception("Define a onExecuting callback"); |