diff --git a/05-userpoints/src/main/java/com/mashibing/listener/UserPointsListener.java b/05-userpoints/src/main/java/com/mashibing/listener/UserPointsListener.java
index ea12edb..34b92ca 100644
--- a/05-userpoints/src/main/java/com/mashibing/listener/UserPointsListener.java
+++ b/05-userpoints/src/main/java/com/mashibing/listener/UserPointsListener.java
@@ -15,7 +15,7 @@ import java.io.IOException;
 @Component
 public class UserPointsListener {
 
-    @RabbitListener(queues = {RabbitMQConfig.COUPON_QUEUE})
+    @RabbitListener(queues = {RabbitMQConfig.USER_POINTS_QUEUE})
     public void consume(String msg, Channel channel, Message message) throws InterruptedException, IOException {
         // 预扣除用户积分
         Thread.sleep(400);
diff --git a/06-business/src/main/java/com/mashibing/listener/BusinessListener.java b/06-business/src/main/java/com/mashibing/listener/BusinessListener.java
index 708d53a..1f429d6 100644
--- a/06-business/src/main/java/com/mashibing/listener/BusinessListener.java
+++ b/06-business/src/main/java/com/mashibing/listener/BusinessListener.java
@@ -15,7 +15,7 @@ import java.io.IOException;
 @Component
 public class BusinessListener {
 
-    @RabbitListener(queues = {RabbitMQConfig.COUPON_QUEUE})
+    @RabbitListener(queues = {RabbitMQConfig.BUSINESS_QUEUE})
     public void consume(String msg, Channel channel, Message message) throws InterruptedException, IOException {
         // 通知商家成功！
         Thread.sleep(400);