only consume 1 message and release blocking thread

treehouselabs · Jul 14, 2015 · 1aadb99 · 1aadb99
1 parent 836b58f
commit 1aadb99
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/TreeHouse/Queue/Message/Provider/AmqpMessageProvider.php b/src/TreeHouse/Queue/Message/Provider/AmqpMessageProvider.php
@@ -65,6 +65,9 @@ public function consume(callable $callback)
             $message = new Message($body, $props, $id);
 
             $callback($message);
+
+            // release blocking thread back to php
+            return false;
         });
     }
 }