Gendoria / command-queue-rabbitmq-bundle

src/Gendoria/CommandQueueRabbitMqDriverBundle/Worker/RabbitMqWorker.php

Spacing +4 added lines, -4 removed lines

@@ -124,18 +124,18 @@
         $triesNum = 10;
         $headers = $msg->get('application_headers')->getNativeData();
         $retryCount = $this->getRetryCount($headers);
-        $retry = ($retryCount < $triesNum - 1);
-        $resheduleInS = (5 * $retryCount + 10);
+        $retry = ($retryCount < $triesNum-1);
+        $resheduleInS = (5 * $retryCount+10);
 
         $this->logger->error(
             sprintf(
-                'Error while executing processor (retry count: %d - %s): %s', $retryCount + 1, $retry ? 'retry in ' . $resheduleInS . 's' : 'reject', $e->getMessage()
+                'Error while executing processor (retry count: %d - %s): %s', $retryCount+1, $retry ? 'retry in '.$resheduleInS.'s' : 'reject', $e->getMessage()
             ), array($e->getTraceAsString(), $this, $processor)
         );
 
         if ($retry) {
             $this->rescheduleProducer->publish(
-                $msg->body, (string)$msg->delivery_info['routing_key'], array_merge(
+                $msg->body, (string) $msg->delivery_info['routing_key'], array_merge(
                     $msg->get_properties(), array('expiration' => $resheduleInS * 1000)
                 )
             );

src/Gendoria/CommandQueueRabbitMqDriverBundle/Listener/ClearEntityManagersListener.php

Unused Use Statements -1 removed lines

@@ -3,7 +3,6 @@
 namespace Gendoria\CommandQueueRabbitMqDriverBundle\Listener;
 
 use Doctrine\Common\Persistence\ManagerRegistry;
-use Doctrine\ORM\EntityManager;
 use Gendoria\CommandQueueBundle\Event\QueueBeforeTranslateEvent;
 use Gendoria\CommandQueueBundle\Event\QueueEvents;
 use Gendoria\CommandQueueBundle\Event\QueueProcessEvent;