| @@ -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 | 
| @@ -68,7 +68,7 @@ | ||
| 68 | 68 | */ | 
| 69 | 69 | public function handle() | 
| 70 | 70 |      { | 
| 71 | -        $this->driver->wait(function (MessageInterface $message) { | |
| 71 | +        $this->driver->wait(function(MessageInterface $message) { | |
| 72 | 72 | $this->log( | 
| 73 | 73 | LogLevel::INFO, | 
| 74 | 74 |                  "Start handle message #{$message->getId()} ({$message->getType()})", | 
| @@ -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 | } |