From 26c0d3d4c8bd9d4a76184646da1eda1569b8de7c Mon Sep 17 00:00:00 2001 From: xinzirun Date: Mon, 7 Oct 2024 13:55:46 +0800 Subject: [PATCH] =?UTF-8?q?fix():=20=E4=BC=98=E5=8C=96=E4=B8=8A=E4=B8=8B?= =?UTF-8?q?=E7=BA=BF=E7=9B=91=E5=90=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/muyu/event/process/consumer/GoOfflineConsumer.java | 3 ++- .../com/muyu/event/process/consumer/GoOnlineConsumer.java | 6 ++++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/GoOfflineConsumer.java b/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/GoOfflineConsumer.java index 773b91e..99810c2 100644 --- a/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/GoOfflineConsumer.java +++ b/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/GoOfflineConsumer.java @@ -3,6 +3,7 @@ package com.muyu.event.process.consumer; import com.muyu.event.process.util.CacheUtil; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; +import org.springframework.amqp.core.ExchangeTypes; import org.springframework.amqp.rabbit.annotation.Exchange; import org.springframework.amqp.rabbit.annotation.Queue; import org.springframework.amqp.rabbit.annotation.QueueBinding; @@ -32,7 +33,7 @@ public class GoOfflineConsumer { @RabbitListener( bindings = @QueueBinding( value = @Queue(value = "GO_OFFLINE", durable = "true"), - exchange = @Exchange(value = "OFFLINE_EXCHANGE", type = "fanout") + exchange = @Exchange(value = "OFFLINE_EXCHANGE", type = ExchangeTypes.FANOUT) ) ) public void offline(String vin) { diff --git a/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/GoOnlineConsumer.java b/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/GoOnlineConsumer.java index f5fc581..ff0e571 100644 --- a/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/GoOnlineConsumer.java +++ b/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/GoOnlineConsumer.java @@ -8,6 +8,7 @@ import com.muyu.event.process.constant.CacheHandlerConstants; import com.muyu.event.process.util.CacheUtil; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; +import org.springframework.amqp.core.ExchangeTypes; import org.springframework.amqp.rabbit.annotation.Exchange; import org.springframework.amqp.rabbit.annotation.Queue; import org.springframework.amqp.rabbit.annotation.QueueBinding; @@ -19,7 +20,7 @@ import java.util.HashMap; /** * @Author: zi run * @Date 2024/10/6 10:01 - * @Description 商量上线消费者 + * @Description 车辆上线消费者 */ @Slf4j @Component @@ -53,12 +54,13 @@ public class GoOnlineConsumer { /** * 处理车辆上线事件 + * * @param vin 车辆的识别码，根据识别码从缓存中存入对应的数据 */ @RabbitListener( bindings = @QueueBinding( value = @Queue(value = "GO_ONLINE", durable = "true"), - exchange = @Exchange(value = "ONLINE_EXCHANGE", type = "fanout") + exchange = @Exchange(value = "ONLINE_EXCHANGE", type = ExchangeTypes.FANOUT) ) ) public void online(String vin) {