From 153cc3fd4ef015a8b1390b2eef3d102c5859a5e7 Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期五, 29 三月 2024 16:07:48 +0800
Subject: [PATCH] dnc Module error fix
---
smart-man-boot/src/main/java/com/qianwen/smartman/modules/dmpLog/message/consumer/DmpLogSyncConsumer.java | 6 ++++--
1 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/dmpLog/message/consumer/DmpLogSyncConsumer.java b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/dmpLog/message/consumer/DmpLogSyncConsumer.java
index 4b98f42..340cd2d 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/dmpLog/message/consumer/DmpLogSyncConsumer.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/dmpLog/message/consumer/DmpLogSyncConsumer.java
@@ -25,9 +25,11 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
+/**
+ * 鍒╃敤rockmq锛屼粠鏃ュ織涓績鎺ュ彈鏃ュ織淇℃伅瀛樺叆鏈湴搴搕dengine涓�
+ */
@RocketMQMessageListener(consumerGroup = DmpLogSyncConstant.CONSUMER_GROUP, topic = DmpLogSyncConstant.DMP_LOG_TOPIC)
@Component
-/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/dmpLog/message/consumer/DmpLogSyncConsumer.class */
public class DmpLogSyncConsumer implements RocketMQListener<DmpLogMessage>, RocketMQPushConsumerLifecycleListener {
private DateTimeFormatter fmt = DateTimeFormatter.ofPattern("yyyyMM");
@Autowired
@@ -40,7 +42,7 @@
public void onMessage(DmpLogMessage dmpLogMessage) {
JSONObject jsonObject = dmpLogMessage.getMessage();
if (Func.isNotEmpty(jsonObject)) {
- jsonObject.getInteger("Type");
+ Integer msgType = jsonObject.getInteger("Type");
try {
switch ((LogTypeEnum) Objects.requireNonNull(LogTypeEnum.getValue(msgType))) {
case Signal:
--
Gitblit v1.9.3