graze / queue

src/Adapter/AdapterInterface.php

Doc Comments +2 added lines

@@ -27,6 +27,7 @@ 
      * @param MessageInterface[] $messages
      *
      * @throws FailedAcknowledgementException
+     * @return void
      */
     public function acknowledge(array $messages);
 
@@ -42,6 +43,7 @@ 
      * @param MessageInterface[] $messages
      *
      * @throws FailedEnqueueException
+     * @return void
      */
     public function enqueue(array $messages);
 

src/ConsumerInterface.php

Doc Comments +1 added lines

@@ -20,6 +20,7 @@
     /**
      * @param callable $worker
      * @param int      $limit
+     * @return void
      */
     public function receive(callable $worker, $limit = 1);
 }

src/ProducerInterface.php

Doc Comments +1 added lines

@@ -20,6 +20,7 @@
     /**
      * @param string $body
      * @param array  $options
+     * @return Message\MessageInterface
      */
     public function create($body, array $options = []);
 

tests/unit/Handler/EagerAcknowledgementHandlerTest.php

Unused Use Statements -1 removed lines

@@ -16,7 +16,6 @@
 namespace Graze\Queue\Handler;
 
 use ArrayIterator;
-use Closure;
 use Graze\Queue\Adapter\AdapterInterface;
 use GuzzleHttp\Message\MessageInterface;
 use Mockery as m;

tests/unit/Handler/NullAcknowledgementHandlerTest.php

Unused Use Statements -1 removed lines

@@ -16,7 +16,6 @@
 namespace Graze\Queue\Handler;
 
 use ArrayIterator;
-use Closure;
 use Graze\Queue\Adapter\AdapterInterface;
 use GuzzleHttp\Message\MessageInterface;
 use Mockery as m;