Microservice/iot
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

云前置改造微调

Browse Source
This commit is contained in:
xy
2025-11-04 14:09:51 +08:00
parent 1d29a03a3c
commit 528f376f6d
3 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
iot-message/message-boot/src/main/java/com/njcn/message/consumer/BzConsumer.java
View File

@@ -13,6 +13,7 @@ import com.njcn.redis.utils.RedisUtil;
import com.njcn.system.api.RocketMqLogFeignClient; import com.njcn.system.api.RocketMqLogFeignClient;
import com.njcn.system.pojo.po.RocketmqMsgErrorLog; import com.njcn.system.pojo.po.RocketmqMsgErrorLog;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.ConsumeMode;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener; import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@@ -30,8 +31,9 @@ import java.util.Objects;
@Service @Service
@RocketMQMessageListener( @RocketMQMessageListener(
topic = BusinessTopic.REPLY_TOPIC, topic = BusinessTopic.REPLY_TOPIC,
consumerGroup = BusinessTopic.REPLY_TOPIC, consumerGroup = "RECALL",
selectorExpression = "RECALL", selectorExpression = "RECALL",
consumeMode = ConsumeMode.ORDERLY,
consumeThreadNumber = 10, consumeThreadNumber = 10,
enableMsgTrace = true enableMsgTrace = true
) )

2
iot-message/message-boot/src/main/java/com/njcn/message/consumer/CldEventConsumer.java
View File

@@ -12,6 +12,7 @@ import com.njcn.system.api.RocketMqLogFeignClient;
import com.njcn.system.pojo.po.RocketmqMsgErrorLog; import com.njcn.system.pojo.po.RocketmqMsgErrorLog;
import com.njcn.zlevent.api.EventFeignClient; import com.njcn.zlevent.api.EventFeignClient;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.ConsumeMode;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener; import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@@ -31,6 +32,7 @@ import java.util.Objects;
topic = BusinessTopic.LOG_TOPIC, topic = BusinessTopic.LOG_TOPIC,
consumerGroup = BusinessTopic.LOG_TOPIC, consumerGroup = BusinessTopic.LOG_TOPIC,
consumeThreadNumber = 10, consumeThreadNumber = 10,
consumeMode = ConsumeMode.ORDERLY,
enableMsgTrace = true enableMsgTrace = true
) )
@Slf4j @Slf4j

4
iot-message/message-boot/src/main/java/com/njcn/message/consumer/UpdateLedgerConsumer.java
View File

@@ -14,6 +14,7 @@ import com.njcn.redis.utils.RedisUtil;
import com.njcn.system.api.RocketMqLogFeignClient; import com.njcn.system.api.RocketMqLogFeignClient;
import com.njcn.system.pojo.po.RocketmqMsgErrorLog; import com.njcn.system.pojo.po.RocketmqMsgErrorLog;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.ConsumeMode;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener; import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@@ -32,8 +33,9 @@ import java.util.Objects;
@Service @Service
@RocketMQMessageListener( @RocketMQMessageListener(
topic = BusinessTopic.REPLY_TOPIC, topic = BusinessTopic.REPLY_TOPIC,
consumerGroup = BusinessTopic.REPLY_TOPIC, consumerGroup = "LEDGER",
selectorExpression = "LEDGER", selectorExpression = "LEDGER",
consumeMode = ConsumeMode.ORDERLY,
consumeThreadNumber = 10, consumeThreadNumber = 10,
enableMsgTrace = true enableMsgTrace = true
) )