tavii / SQSJobQueueBundle

ContainerAwareJob.php

Spacing +1 added lines, -1 removed lines

@@ -46,7 +46,7 @@
      */
     protected function getContainer()
     {
-        if (! $this->kernel instanceof KernelInterface) {
+        if (!$this->kernel instanceof KernelInterface) {
             $this->kernel = $this->createKernel();
             $this->kernel->boot();
         }

Command/QueuePurgeCommand.php

Spacing +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
             $client->purgeQueue(array(
                 'QueueUrl' => $result['QueueUrl']
             ));
-            $output->writeln('<info>pugrge queue url</info>: '. $result['QueueUrl']);
+            $output->writeln('<info>pugrge queue url</info>: '.$result['QueueUrl']);
         } else {
             $output->writeln('cancel purge...');
         }

Command/QueueListCommand.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
     {
         $this->setName('sqs_job_queue:queue-list')
             ->setDescription('list queue')
-            ->addOption('queueNamePrefix', 'Q',InputOption::VALUE_OPTIONAL, 'QueueNamePrefix', '')
+            ->addOption('queueNamePrefix', 'Q', InputOption::VALUE_OPTIONAL, 'QueueNamePrefix', '')
         ;
     }
 

Command/QueueDeleteCommand.php

Spacing +1 added lines, -1 removed lines

@@ -43,7 +43,7 @@
             $client->deleteQueue(array(
                 'QueueUrl' => $result['QueueUrl']
             ));
-            $output->writeln('<info>delete queue url</info>: '. $result['QueueUrl']);
+            $output->writeln('<info>delete queue url</info>: '.$result['QueueUrl']);
         } else {
             $output->writeln('cancel purge...');
         }

Tests/Command/WorkerStatusCommandTest.php

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
         $storage = Phake::mock('Tavii\SQSJobQueueBundle\Storage\DoctrineStorage');
         $container = Phake::mock('Symfony\Component\DependencyInjection\Container');
 
-        $entity = new TestEntity('test','test.com', 12345);
+        $entity = new TestEntity('test', 'test.com', 12345);
 
 
         Phake::when($storage)->all()->thenReturn(array(

Tests/QueueTest.php

Spacing +1 added lines, -1 removed lines

@@ -79,7 +79,7 @@
         $queue = new Queue($baseQueue, $dispatcher, $kernelOptions);
 
         $job = new DummyContainerAwareJob();
-        $message = new Message(array(),$job,'test.com');
+        $message = new Message(array(), $job, 'test.com');
 
         Phake::when($baseQueue)->delete($message)
             ->thenReturn(true);

EventListener/DebugLoggingListener.php

Spacing +5 added lines, -5 removed lines

@@ -40,7 +40,7 @@ 
      */
     public function onQueueReceived(ReceiveQueueEvent $event)
     {
-        $this->logger->debug("Queue Received: ",[
+        $this->logger->debug("Queue Received: ", [
             'queue_url' => $event->getMessage()->getQueueUrl(),
             'job_name' => $event->getMessage()->getJob()->getName(),
         ]);
@@ -51,7 +51,7 @@ 
      */
     public function onQueueSent(SentQueueEvent $event)
     {
-        $this->logger->debug("Queue Send: ",[
+        $this->logger->debug("Queue Send: ", [
             'job_name' => $event->getJob()->getName(),
             'sent' => $event->isSent()
         ]);
@@ -62,7 +62,7 @@ 
      */
     public function onQueueDeleted(DeleteQueueEvent $event)
     {
-        $this->logger->debug("Queue Delete: ",[
+        $this->logger->debug("Queue Delete: ", [
             'queue_url' => $event->getMessage()->getQueueUrl(),
             'job_name' => $event->getMessage()->getJob()->getName(),
             'deleted' => $event->isDeleted()
@@ -75,7 +75,7 @@ 
      */
     public function onJobExecute(JobEvent $event)
     {
-        $this->logger->debug("Job Execute: ",[
+        $this->logger->debug("Job Execute: ", [
             'job_name' => $event->getJob()->getName(),
         ]);
     }
@@ -85,7 +85,7 @@ 
      */
     public function onJobRan(JobEvent $event)
     {
-        $this->logger->debug("Job Ran: ",[
+        $this->logger->debug("Job Ran: ", [
             'job_name' => $event->getJob()->getName(),
             'execute_status' => $event->isExecutedStatus()
         ]);