@@ -1,8 +1,8 @@ |
||
1 | 1 | <?php |
2 | 2 | declare(strict_types=1); |
3 | 3 | |
4 | -use Tomaj\Hermes\Driver\RedisSetDriver; |
|
5 | 4 | use Tomaj\Hermes\Dispatcher; |
5 | +use Tomaj\Hermes\Driver\RedisSetDriver; |
|
6 | 6 | use Tomaj\Hermes\Handler\EchoHandler; |
7 | 7 | use Tomaj\Hermes\Restart\RedisRestart; |
8 | 8 |
@@ -3,16 +3,15 @@ |
||
3 | 3 | |
4 | 4 | namespace Tomaj\Hermes; |
5 | 5 | |
6 | +use DateTime; |
|
6 | 7 | use Exception; |
7 | -use Psr\Log\LoggerInterface; |
|
8 | 8 | use Psr\Log\LogLevel; |
9 | -use Tomaj\Hermes\Driver\RestartTrait; |
|
10 | -use Tomaj\Hermes\Handler\HandlerInterface; |
|
9 | +use Psr\Log\LoggerInterface; |
|
11 | 10 | use Tomaj\Hermes\Driver\DriverInterface; |
11 | +use Tomaj\Hermes\Handler\HandlerInterface; |
|
12 | 12 | use Tomaj\Hermes\Restart\RestartException; |
13 | 13 | use Tomaj\Hermes\Restart\RestartInterface; |
14 | 14 | use Tracy\Debugger; |
15 | -use DateTime; |
|
16 | 15 | |
17 | 16 | class Dispatcher implements DispatcherInterface |
18 | 17 | { |
@@ -2,10 +2,10 @@ |
||
2 | 2 | |
3 | 3 | namespace Tomaj\Hermes\Driver; |
4 | 4 | |
5 | -use Tomaj\Hermes\MessageInterface; |
|
6 | 5 | use Closure; |
7 | -use Tomaj\Hermes\MessageSerializer; |
|
8 | 6 | use InvalidArgumentException; |
7 | +use Tomaj\Hermes\MessageInterface; |
|
8 | +use Tomaj\Hermes\MessageSerializer; |
|
9 | 9 | use Tomaj\Hermes\Restart\RestartException; |
10 | 10 | |
11 | 11 | class RedisSetDriver implements DriverInterface |
@@ -69,7 +69,7 @@ |
||
69 | 69 | true, |
70 | 70 | false, |
71 | 71 | false, |
72 | - function ($rabbitMessage) use ($callback) { |
|
72 | + function($rabbitMessage) use ($callback) { |
|
73 | 73 | $message = $this->serializer->unserialize($rabbitMessage->body); |
74 | 74 | $callback($message); |
75 | 75 | } |