LinioIT / queue

src/Queue/Provider/QueueServiceProvider.php

Spacing +2 added lines, -2 removed lines

@@ -17,14 +17,14 @@
             $container['queue.adapter_name'] = 'null';
         }
 
-        $container['queue.adapter'] = $container->factory(function ($container) {
+        $container['queue.adapter'] = $container->factory(function($container) {
             $adapterFactory = new AdapterFactory();
             $adapter = $adapterFactory->getAdapter($container['queue.adapter_name'], $container['queue.adapter_options']);
 
             return $adapter;
         });
 
-        $container['queue.service'] = function ($container) {
+        $container['queue.service'] = function($container) {
             $queueService = new QueueService();
             $queueService->setAdapter($container['queue.adapter']);
             $queueService->setLogger($container['monolog']);

src/Queue/Adapter/RabbitAdapter.php

Spacing +1 added lines, -1 removed lines

@@ -38,7 +38,7 @@
     {
         $this->getChannel()->queue_declare($job->getQueue(), true, $job->isPersistent(), false, false);
         $this->getChannel()->basic_qos(null, 1, null);
-        $this->getChannel()->basic_consume($job->getQueue(), '', false, false, false, false, function ($message) use ($job) {
+        $this->getChannel()->basic_consume($job->getQueue(), '', false, false, false, false, function($message) use ($job) {
             $job->setPayload($message->body);
             $job->perform();