From 3f82ff3ff1ef00fad0296b3ea94229c660e02679 Mon Sep 17 00:00:00 2001 From: ant Date: Mon, 29 Jul 2024 10:00:36 +0800 Subject: [PATCH] =?UTF-8?q?1.=20=E6=89=93=E5=BC=80=20ins=E7=9A=84rocket?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../chushang/inspection/consumer/InspectionConsumerService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/consumer/InspectionConsumerService.java b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/consumer/InspectionConsumerService.java index 2161e6e..3b9ebda 100644 --- a/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/consumer/InspectionConsumerService.java +++ b/chushang-modules/chushang-module-inspection/inspection-service/src/main/java/com/chushang/inspection/consumer/InspectionConsumerService.java @@ -33,7 +33,7 @@ import java.util.Objects; */ @Slf4j @Component -//@RocketMQMessageListener(topic = ServiceConstant.INSPECTION + 1, consumerGroup = ServiceConstant.INSPECTION_CONSUMER_GROUP) +@RocketMQMessageListener(topic = ServiceConstant.INSPECTION + 1, consumerGroup = ServiceConstant.INSPECTION_CONSUMER_GROUP) public class InspectionConsumerService implements RocketMQListener { @Resource RemoteTaskService remoteTaskService;