@@ -12,7 +12,7 @@ |
||
12 | 12 | private $redis; |
13 | 13 | |
14 | 14 | /** |
15 | - * @param Redis $redis |
|
15 | + * @param \PHPUnit_Framework_MockObject_MockObject $redis |
|
16 | 16 | */ |
17 | 17 | public function __construct(Redis $redis) |
18 | 18 | { |
@@ -1,6 +1,6 @@ |
||
1 | 1 | <?php |
2 | 2 | |
3 | -require __DIR__ . '/../vendor/autoload.php'; |
|
3 | +require __DIR__.'/../vendor/autoload.php'; |
|
4 | 4 | require 'ExampleJob.php'; |
5 | 5 | |
6 | 6 | use Equip\Queue\Driver\RedisDriver; |
@@ -42,7 +42,7 @@ discard block |
||
42 | 42 | { |
43 | 43 | $name = 'test'; |
44 | 44 | $routes = [ |
45 | - $name => function () {}, |
|
45 | + $name => function() {}, |
|
46 | 46 | ]; |
47 | 47 | |
48 | 48 | $method = static::getProtectedMethod($this->worker, 'getHandler'); |
@@ -124,7 +124,7 @@ discard block |
||
124 | 124 | $this->driver, |
125 | 125 | $this->event, |
126 | 126 | $this->serializer, |
127 | - ['foo' => function () use ($exception) { throw $exception; }] |
|
127 | + ['foo' => function() use ($exception) { throw $exception; }] |
|
128 | 128 | ); |
129 | 129 | |
130 | 130 | $method = static::getProtectedMethod($worker, 'tick'); |
@@ -150,7 +150,7 @@ discard block |
||
150 | 150 | $this->driver, |
151 | 151 | $this->event, |
152 | 152 | $this->serializer, |
153 | - ['foo' => function () { return false; }] |
|
153 | + ['foo' => function() { return false; }] |
|
154 | 154 | ); |
155 | 155 | |
156 | 156 | $method = static::getProtectedMethod($worker, 'tick'); |
@@ -177,7 +177,7 @@ discard block |
||
177 | 177 | $this->event, |
178 | 178 | $this->serializer, |
179 | 179 | [ |
180 | - 'foo' => function ($data) use ($message) { |
|
180 | + 'foo' => function($data) use ($message) { |
|
181 | 181 | $this->assertSame($message->handler(), $data->handler()); |
182 | 182 | } |
183 | 183 | ] |
@@ -206,7 +206,7 @@ discard block |
||
206 | 206 | $this->driver, |
207 | 207 | $this->event, |
208 | 208 | $this->serializer, |
209 | - ['foo' => function () { return false; }] |
|
209 | + ['foo' => function() { return false; }] |
|
210 | 210 | ); |
211 | 211 | |
212 | 212 | $worker->consume($message->queue()); |
@@ -69,7 +69,7 @@ |
||
69 | 69 | { |
70 | 70 | $packet = $this->driver->pop($queue); |
71 | 71 | if (empty($packet)) { |
72 | - return true; |
|
72 | + return true; |
|
73 | 73 | } |
74 | 74 | |
75 | 75 | $message = $this->serializer->deserialize($packet); |
@@ -1,6 +1,6 @@ |
||
1 | 1 | <?php |
2 | 2 | |
3 | -require __DIR__ . '/../vendor/autoload.php'; |
|
3 | +require __DIR__.'/../vendor/autoload.php'; |
|
4 | 4 | require 'ExampleJob.php'; |
5 | 5 | |
6 | 6 | use Equip\Queue\Driver\RedisDriver; |
@@ -47,7 +47,7 @@ |
||
47 | 47 | public function finish(Message $message) |
48 | 48 | { |
49 | 49 | array_map(function ($name) use ($message) { |
50 | - $this->emitter->emit($name, $message) ; |
|
50 | + $this->emitter->emit($name, $message) ; |
|
51 | 51 | }, [ |
52 | 52 | static::MESSAGE_FINISH, |
53 | 53 | sprintf('%s.%s', static::MESSAGE_FINISH, $message->handler()) |
@@ -31,7 +31,7 @@ discard block |
||
31 | 31 | */ |
32 | 32 | public function acknowledge(Message $message) |
33 | 33 | { |
34 | - array_map(function ($name) use ($message) { |
|
34 | + array_map(function($name) use ($message) { |
|
35 | 35 | $this->emitter->emit($name, $message); |
36 | 36 | }, [ |
37 | 37 | static::MESSAGE_ACKNOWLEDGE, |
@@ -46,8 +46,8 @@ discard block |
||
46 | 46 | */ |
47 | 47 | public function finish(Message $message) |
48 | 48 | { |
49 | - array_map(function ($name) use ($message) { |
|
50 | - $this->emitter->emit($name, $message) ; |
|
49 | + array_map(function($name) use ($message) { |
|
50 | + $this->emitter->emit($name, $message); |
|
51 | 51 | }, [ |
52 | 52 | static::MESSAGE_FINISH, |
53 | 53 | sprintf('%s.%s', static::MESSAGE_FINISH, $message->handler()) |
@@ -62,7 +62,7 @@ discard block |
||
62 | 62 | */ |
63 | 63 | public function reject(Message $message, Exception $exception) |
64 | 64 | { |
65 | - array_map(function ($name) use ($message, $exception) { |
|
65 | + array_map(function($name) use ($message, $exception) { |
|
66 | 66 | $this->emitter->emit($name, $message, $exception); |
67 | 67 | }, [ |
68 | 68 | static::MESSAGE_REJECT, |