队列

5 years ago · 765dbccf8f
1 changed files with 3 additions and 0 deletions
--- a/app/Amqp/Consumer/couponRebateConsumer.php
+++ b/app/Amqp/Consumer/couponRebateConsumer.php
@ -18,6 +18,9 @@ class couponRebateConsumer extends ConsumerMessage
    {
        var_dump($data);
        var_dump($message->getBody());
+        if (false) {
+            return Result::REQUEUE;
+        }
        return Result::ACK;
    }