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 = []);