Browse Source

队列

master
parent
commit
907bc49551
  1. 4
      app/Amqp/Consumer/couponRebateConsumer.php

4
app/Amqp/Consumer/couponRebateConsumer.php

@ -28,11 +28,7 @@ class couponRebateConsumer extends ConsumerMessage
public function consumeMessage($data, AMQPMessage $message): string
{
//var_dump($data);
//ar_dump($rebate_id);
//var_dump($message->getBody());
$res = $this->CouponRebateService->couponRebate($data);
//var_dump($res);
if (!$res) {
return Result::REQUEUE;
}

Loading…
Cancel
Save