@@ -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()})", |