From becd6e50d89cbdab910a3964b6ef82f79ed99bec Mon Sep 17 00:00:00 2001 From: Administrator Date: Wed, 22 Mar 2023 22:04:15 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9E=E7=8E=B0=E5=BC=82=E6=AD=A5=E8=B0=83?= =?UTF-8?q?=E7=94=A8=EF=BC=88=E7=94=A8=E6=88=B7=E7=A7=AF=E5=88=86&?= =?UTF-8?q?=E5=95=86=E5=AE=B6=E6=9C=8D=E5=8A=A1=E6=B6=88=E8=B4=B9=E6=B6=88?= =?UTF-8?q?=E6=81=AF=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/mashibing/listener/UserPointsListener.java | 2 +- .../src/main/java/com/mashibing/listener/BusinessListener.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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);