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);
 }