tavii / SQSJobQueueBundle

Entity/SqsWorker.php

Doc Comments +5 added lines, -5 removed lines

@@ -62,7 +62,7 @@ 
     }
 
     /**
-     * @param $server
+     * @param string $server
      * @return $this
      */
     public function setServer($server)
@@ -80,7 +80,7 @@ 
     }
 
     /**
-     * @param $queue
+     * @param string $queue
      * @return $this
      */
     public function setQueue($queue)
@@ -90,7 +90,7 @@ 
     }
 
     /**
-     * @return mixed
+     * @return integer
      */
     public function getProcId()
     {
@@ -116,7 +116,7 @@ 
     }
 
     /**
-     * @return mixed
+     * @return \DateTime
      */
     public function getCreatedAt()
     {
@@ -134,7 +134,7 @@ 
     }
 
     /**
-     * @return mixed
+     * @return \DateTime
      */
     public function getUpdatedAt()
     {

Queue.php

Doc Comments +1 added lines

@@ -43,6 +43,7 @@
 
     /**
      * {@inheritdoc}
+     * @param string $name
      */
     public function receive($name)
     {

Storage/DoctrineStorage.php

Unused Use Statements -1 removed lines

@@ -7,7 +7,6 @@
 use Tavii\SQSJobQueue\Storage\EntityInterface;
 use Tavii\SQSJobQueue\Storage\StorageInterface;
 use Tavii\SQSJobQueueBundle\Entity\SqsWorker;
-use Tavii\SQSJobQueueBundle\Exception\EntityNotFoundException;
 
 class DoctrineStorage implements StorageInterface
 {

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);