@@ -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"); |