tavii / SQSJobQueue

Tests/Queue/QueueTest.php

Doc Comments +1 added lines, -2 removed lines

@@ -103,8 +103,7 @@
 class DummyJob extends Job
 {
     /**
-     * @param array $args
-     * @return booelan
+     * @return boolean
      */
     public function run()
     {

Spacing +2 added lines, -2 removed lines

@@ -24,7 +24,7 @@ 
         Phake::when($job)->getName()
             ->thenReturn($name);
         Phake::when($job)->getArgs()
-            ->thenReturn(array('test','teset2'));
+            ->thenReturn(array('test', 'teset2'));
 
         Phake::when($this->client)->getQueueUrl(array('QueueName' => $name))
             ->thenReturn(array(
@@ -51,7 +51,7 @@ 
         $args = array(
             'Body' => json_encode(array(
                 'className' => 'Tavii\SQSJobQueue\Queue\DummyJob',
-                'args' => array('a' => '1' , 'b' => 2)
+                'args' => array('a' => '1', 'b' => 2)
             ))
         );
 

Tests/Job/JobTest.php

Spacing +1 added lines, -1 removed lines

@@ -11,7 +11,7 @@
     {
         $args = array('1' => 'a', 'b' => '3');
         $job = new TestJob($args);
-        $this->assertEquals("Tavii\\SQSJobQueue\\Job\\TestJob",$job->getClassName());
+        $this->assertEquals("Tavii\\SQSJobQueue\\Job\\TestJob", $job->getClassName());
         $this->assertEquals("test_job", $job->getName());
         $this->assertInternalType('array', $job->getArgs());
         $this->assertEquals($args, $job->getArgs());

Tests/Worker/WorkerTest.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
         $worker = new Worker($queue, $storage);
         $actual = $worker->run($name);
 
-        Phake::verify($queue)->receive ($name);
+        Phake::verify($queue)->receive($name);
         Phake::verify($message)->getJob();
         Phake::verify($job)->execute();
         Phake::verify($queue)->delete($message);

Doc Comments +2 added lines

@@ -182,6 +182,8 @@
 
     /**
      * {@inheritdoc}
+     * @param string $server
+     * @param integer $procId
      */
     public function __construct($queue, $server, $procId)
     {

Worker/Worker.php

Spacing +1 added lines, -1 removed lines

@@ -62,7 +62,7 @@
             }
             $this->storage->set($name, $server, $pid);
         } else {
-            while(true) {
+            while (true) {
                 $this->run($name);
                 sleep($sleep);
             }

Tests/Message/MessageTest.php

Doc Comments +1 added lines, -2 removed lines

@@ -103,8 +103,7 @@
 class DummyJob extends Job
 {
     /**
-     * @param array $args
-     * @return booelan
+     * @return boolean
      */
     public function run()
     {

Storage/StorageInterface.php

Doc Comments +1 added lines, -4 removed lines

@@ -26,7 +26,6 @@ 
      * @param JobName $jobName
      * @param string $server
      * @param int $procId
-     * @param string $prefix
      * @return void
      */
     public function set(JobName $jobName, $server, $procId);
@@ -35,7 +34,6 @@ 
      * @param JobName $jobName
      * @param string $server
      * @param int $procId
-     * @param string $prefix
      * @return array
      */
     public function get(JobName $jobName, $server, $procId);
@@ -44,7 +42,6 @@ 
      * @param JobName $jobName
      * @param string $server
      * @param string $procId
-     * @param string $prefix
      * @return mixed
      */
     public function remove(JobName $jobName, $server, $procId);
@@ -52,7 +49,7 @@ 
 
     /**
      * @param JobName $jobName
-     * @param $server
+     * @param string $server
      * @return void
      */
     public function removeForce(JobName $jobName, $server);

Job/Job.php

Doc Comments +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
     abstract protected function run();
 
     /**
-     * @return string
+     * @return QueueName
      */
     public function getJobName()
     {

Queue/QueueName.php

Doc Comments -1 removed lines

@@ -24,7 +24,6 @@
      * JobName constructor.
      * @param string $name
      * @param string $prefix
-     * @param string $separator
      */
     public function __construct($name, $prefix)
     {

Spacing +1 added lines, -1 removed lines

@@ -40,6 +40,6 @@
         if (empty($this->prefix)) {
             return $this->name;
         }
-        return $this->prefix . "_" . $this->name;
+        return $this->prefix."_".$this->name;
     }
 }
\ No newline at end of file