equip / queue

src/Driver/RedisDriver.php

Doc Comments +1 added lines, -1 removed lines

@@ -12,7 +12,7 @@
     private $redis;
 
     /**
-     * @param Redis $redis
+     * @param \PHPUnit_Framework_MockObject_MockObject $redis
      */
     public function __construct(Redis $redis)
     {

example/consumer.php

Spacing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-require __DIR__ . '/../vendor/autoload.php';
+require __DIR__.'/../vendor/autoload.php';
 require 'ExampleJob.php';
 
 use Equip\Queue\Driver\RedisDriver;

tests/WorkerTest.php

Spacing +5 added lines, -5 removed lines

@@ -42,7 +42,7 @@ 
     {
         $name = 'test';
         $routes = [
-            $name => function () {},
+            $name => function() {},
         ];
 
         $method = static::getProtectedMethod($this->worker, 'getHandler');
@@ -124,7 +124,7 @@ 
             $this->driver,
             $this->event,
             $this->serializer,
-            ['foo' => function () use ($exception) { throw $exception; }]
+            ['foo' => function() use ($exception) { throw $exception; }]
         );
 
         $method = static::getProtectedMethod($worker, 'tick');
@@ -150,7 +150,7 @@ 
             $this->driver,
             $this->event,
             $this->serializer,
-            ['foo' => function () { return false; }]
+            ['foo' => function() { return false; }]
         );
 
         $method = static::getProtectedMethod($worker, 'tick');
@@ -177,7 +177,7 @@ 
             $this->event,
             $this->serializer,
             [
-                'foo' => function ($data) use ($message) {
+                'foo' => function($data) use ($message) {
                     $this->assertSame($message->handler(), $data->handler());
                 }
             ]
@@ -206,7 +206,7 @@ 
             $this->driver,
             $this->event,
             $this->serializer,
-            ['foo' => function () { return false; }]
+            ['foo' => function() { return false; }]
         );
 
         $worker->consume($message->queue());

src/Worker.php

Indentation +1 added lines, -1 removed lines

@@ -69,7 +69,7 @@
     {
         $packet = $this->driver->pop($queue);
         if (empty($packet)) {
-             return true;
+                return true;
         }
 
         $message = $this->serializer->deserialize($packet);

src/Event.php

Spacing +2 added lines, -2 removed lines

@@ -30,7 +30,7 @@ 
      */
     public function acknowledge(Message $message)
     {
-        array_map(function ($name) use ($message) {
+        array_map(function($name) use ($message) {
             $this->emitter->emit($name, $message);
         }, [
             static::QUEUE_ACKNOWLEDGE,
@@ -46,7 +46,7 @@ 
      */
     public function reject(Message $message, Exception $exception)
     {
-        array_map(function ($name) use ($message, $exception) {
+        array_map(function($name) use ($message, $exception) {
             $this->emitter->emit($name, $message, $exception);
         }, [
             static::QUEUE_REJECT,

example/producer.php

Spacing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-require __DIR__ . '/../vendor/autoload.php';
+require __DIR__.'/../vendor/autoload.php';
 require 'ExampleJob.php';
 
 use Equip\Queue\Driver\RedisDriver;