修改amqp配置

app/Amqp/Consumer/couponRebateConsumer.php

@@ -16,7 +16,7 @@ use Hyperf\Di\Annotation\Inject;
 
 
 /**
- * @Consumer(exchange="couponRebate", routingKey="couponRebate", queue="couponRebate", name ="couponRebateConsumer", nums=1)
+ * @Consumer(exchange="deviceCouponRebate", routingKey="deviceCouponRebate", queue="deviceCouponRebate", name ="couponRebateConsumer", nums=1)
  */
 class couponRebateConsumer extends ConsumerMessage
 {
@@ -28,6 +28,7 @@ class couponRebateConsumer extends ConsumerMessage
 
     public function consumeMessage($data, AMQPMessage $message): string
     {
+        var_dump($data);
         $res = $this->CouponRebateService->couponRebate($data);
         if (!$res) {
             return Result::REQUEUE;