@@ -2,11 +2,10 @@ |
||
2 | 2 | |
3 | 3 | namespace Tomaj\Hermes\Driver; |
4 | 4 | |
5 | -use Exception; |
|
6 | -use Tomaj\Hermes\MessageInterface; |
|
7 | 5 | use Closure; |
8 | -use Tomaj\Hermes\MessageSerializer; |
|
9 | 6 | use InvalidArgumentException; |
7 | +use Tomaj\Hermes\MessageInterface; |
|
8 | +use Tomaj\Hermes\MessageSerializer; |
|
10 | 9 | |
11 | 10 | class RedisSetDriver implements DriverInterface |
12 | 11 | { |
@@ -2,9 +2,9 @@ |
||
2 | 2 | |
3 | 3 | namespace Tomaj\Hermes\Driver; |
4 | 4 | |
5 | +use Closure; |
|
5 | 6 | use Tomaj\Hermes\MessageInterface; |
6 | 7 | use Tomaj\Hermes\MessageSerializer; |
7 | -use Closure; |
|
8 | 8 | use ZMQSocket; |
9 | 9 | |
10 | 10 | class ZeroMqDriver implements DriverInterface |
@@ -62,7 +62,7 @@ |
||
62 | 62 | true, |
63 | 63 | false, |
64 | 64 | false, |
65 | - function ($rabbitMessage) use ($callback) { |
|
65 | + function($rabbitMessage) use ($callback) { |
|
66 | 66 | $message = $this->serializer->unserialize($rabbitMessage->body); |
67 | 67 | $callback($message); |
68 | 68 | } |
@@ -2,16 +2,15 @@ |
||
2 | 2 | |
3 | 3 | namespace Tomaj\Hermes; |
4 | 4 | |
5 | +use DateTime; |
|
5 | 6 | use Exception; |
6 | -use Nette\Application\AbortException; |
|
7 | -use Psr\Log\LoggerInterface; |
|
8 | 7 | use Psr\Log\LogLevel; |
9 | -use Tomaj\Hermes\Handler\HandlerInterface; |
|
8 | +use Psr\Log\LoggerInterface; |
|
10 | 9 | use Tomaj\Hermes\Driver\DriverInterface; |
10 | +use Tomaj\Hermes\Handler\HandlerInterface; |
|
11 | 11 | use Tomaj\Hermes\Restart\RestartException; |
12 | 12 | use Tomaj\Hermes\Restart\RestartInterface; |
13 | 13 | use Tracy\Debugger; |
14 | -use DateTime; |
|
15 | 14 | |
16 | 15 | class Dispatcher implements DispatcherInterface |
17 | 16 | { |
@@ -90,7 +90,7 @@ |
||
90 | 90 | public function handle() |
91 | 91 | { |
92 | 92 | try { |
93 | - $this->driver->wait(function (MessageInterface $message) { |
|
93 | + $this->driver->wait(function(MessageInterface $message) { |
|
94 | 94 | $this->log( |
95 | 95 | LogLevel::INFO, |
96 | 96 | "Start handle message #{$message->getId()} ({$message->getType()})", |