diff --git a/app/Amqp/Consumer/couponRebateConsumer.php b/app/Amqp/Consumer/couponRebateConsumer.php
index 239aee7..bca6310 100644
--- a/app/Amqp/Consumer/couponRebateConsumer.php
+++ b/app/Amqp/Consumer/couponRebateConsumer.php
@@ -16,7 +16,7 @@ use Hyperf\Di\Annotation\Inject;
 
 
 /**
- * @Consumer(exchange="couponRebate1", routingKey="couponRebate1", queue="couponRebate1", name ="couponRebateConsumer", nums=1)
+ * @Consumer(exchange="couponRebate", routingKey="couponRebate", queue="couponRebate", name ="couponRebateConsumer", nums=1)
  */
 class couponRebateConsumer extends ConsumerMessage
 {
diff --git a/composer.json b/composer.json
index 5553ffb..6c643dd 100644
--- a/composer.json
+++ b/composer.json
@@ -31,7 +31,9 @@
         "xxtime/flysystem-aliyun-oss": "^1.5",
 		"hyperf/validation": "^2.0",
         "hyperf/task": "^2.0",
-        "hyperf/paginator": "^2.0"
+        "hyperf/paginator": "^2.0",
+        "hyperf/amqp": "^2.0",
+        "alibabacloud/iot": "^1.8"
     },
     "require-dev": {
         "swoole/ide-helper": "^4.5",