liverbool / dos-queue-bundle

DependencyInjection/Compiler/CustomProviderPass.php

Spacing +2 added lines, -2 removed lines

@@ -19,7 +19,7 @@ 
 
         $configs = $container->getExtensionConfig('uecode_qpush');
 
-        foreach($configs[0]['queues'] as $queue => $value) {
+        foreach ($configs[0]['queues'] as $queue => $value) {
             $definition = clone $container->getDefinition('dos.queue.provider.doctrine_orm');
             $definition->replaceArgument(0, $queue);
             $definition->replaceArgument(1, $value['options']);
@@ -30,7 +30,7 @@ 
                 $definition->addMethodCall('setEventDispatcher', array(new Reference('debug.event_dispatcher')));
             }
 
-            $container->getDefinition('uecode_qpush.'. $queue)->replaceArgument(2, $definition);
+            $container->getDefinition('uecode_qpush.'.$queue)->replaceArgument(2, $definition);
             $container->setDefinition(sprintf('uecode_qpush.%s', $queue), $definition)
                 ->addTag('monolog.logger', ['channel' => 'qpush'])
                 ->addTag('kernel.event_listener', array(

Provider/DoctrineProvider.php

Spacing +2 added lines, -2 removed lines

@@ -173,7 +173,7 @@ 
         $messages = array();
 
         /** @var QueueMessageInterface $message */
-        foreach($results as $message)
+        foreach ($results as $message)
         {
             $message->setReceivedAt(new \DateTime());
 
@@ -223,7 +223,7 @@ 
                 ->where('o.name = :name')
                 ->setParameter('name', $this->getNameWithPrefix())
             ;
-        } catch ( \Exception $e) {
+        } catch (\Exception $e) {
             if (false !== strpos($e->getMessage(), "Queue not found")) {
                 $this->log(400, "Queue did not exist");
             } else {