实现异步调用（用户积分&商家服务消费消息）

3 years ago · becd6e50d8
parent 34b92f0411
commit becd6e50d8
2 changed files with 2 additions and 2 deletions
--- 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);
--- 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);