bschmitt#1 added reject method

slowpokefarm · Jan 5, 2016 · 959589a · 959589a
1 parent 6b9a558
commit 959589a
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 1 deletion.
diff --git a/src/Consumer.php b/src/Consumer.php
@@ -18,6 +18,7 @@ class Consumer extends Request
      * @param string  $queue
      * @param Closure $closure
      * @return bool
+     * @throws \Exception
      */
     public function consume($queue, Closure $closure)
     {
@@ -75,6 +76,8 @@ function ($message) use ($closure, $object) {
     }
 
     /**
+     * Acknowledges a message
+     *
      * @param Message $message
      */
     public function acknowledge($message)
@@ -87,6 +90,19 @@ public function acknowledge($message)
     }
 
     /**
+     * Rejects a message and requeues it if wanted (default: false)
+     *
+     * @param Message $message
+     * @param bool    $requeue
+     */
+    public function reject($message, $requeue = false)
+    {
+        $message->delivery_info['channel']->basic_reject($message->delivery_info['delivery_tag'], $requeue);
+    }
+
+    /**
+     * Stops consumer when no message is left
+     *
      * @throws Exception\Stop
      */
     public function stopWhenProcessed()

diff --git a/src/Message.php b/src/Message.php
@@ -9,4 +9,3 @@ class Message extends AMQPMessage
 {
 
 }
-
Original file line number	Diff line number	Diff line change
Expand Up		@@ -9,4 +9,3 @@ class Message extends AMQPMessage
		{

		}