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

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

tests/unit/Adapter/FirehoseAdapterTest.php

Unused Use Statements -1 removed lines

@@ -17,7 +17,6 @@
 
 use Aws\ResultInterface;
 use Aws\Firehose\FirehoseClient;
-use Graze\DataStructure\Container\ContainerInterface;
 use Graze\Queue\Adapter\Exception\MethodNotSupportedException;
 use Graze\Queue\Message\MessageFactoryInterface;
 use Graze\Queue\Message\MessageInterface;