@@ -100,7 +100,7 @@ discard block |
||
| 100 | 100 | { |
| 101 | 101 | $redis = $this->redis; |
| 102 | 102 | $that = $this; |
| 103 | - $this->redis->pipeline(function () use ($redis, $workerId, $that) { |
|
| 103 | + $this->redis->pipeline(function() use ($redis, $workerId, $that) { |
|
| 104 | 104 | $redis->sadd("workers", $workerId); |
| 105 | 105 | $that->workerStarted($workerId); |
| 106 | 106 | }); |
@@ -110,7 +110,7 @@ discard block |
||
| 110 | 110 | { |
| 111 | 111 | $redis = $this->redis; |
| 112 | 112 | $that = $this; |
| 113 | - $redis->pipeline(function () use ($redis, $workerId, $that) { |
|
| 113 | + $redis->pipeline(function() use ($redis, $workerId, $that) { |
|
| 114 | 114 | $redis->srem("workers", $workerId); |
| 115 | 115 | $redis->del($that->redisKeyForWorker($workerId)); |
| 116 | 116 | $redis->del($that->redisKeyForWorkerStartTime($workerId)); |
@@ -202,7 +202,7 @@ discard block |
||
| 202 | 202 | { |
| 203 | 203 | $redis = $this->redis; |
| 204 | 204 | $workerKey = $this->redisKeyForWorker($workerId); |
| 205 | - $this->redis->pipeline(function () use ($redis, $workerKey, $block) { |
|
| 205 | + $this->redis->pipeline(function() use ($redis, $workerKey, $block) { |
|
| 206 | 206 | $redis->del($workerKey); |
| 207 | 207 | $block(); |
| 208 | 208 | }); |