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 +3 added lines

@@ -180,6 +180,9 @@
 
     /**
      * {@inheritdoc}
+     * @param string $queue
+     * @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()
     {

Job/Job.php

Spacing +1 added lines, -1 removed lines

@@ -38,7 +38,7 @@
      */
     public function getQueueName()
     {
-        return $this->getPrefix() . '_' . $this->getName();
+        return $this->getPrefix().'_'.$this->getName();
     }