by2025/SmartParks
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复打包失败
All checks were successful
Build and Push to Target Registry / 构建并推送镜像到目标仓库 (push) Successful in 12m8s
Details

Browse Source
This commit is contained in:
lxj
2025-08-27 18:37:12 +08:00
parent df9adf700c
commit 1eb95bf6f6
1 changed files with 44 additions and 44 deletions
Download Patch File Download Diff File Expand all files Collapse all files

88
ruoyi-modules/Sis/src/main/java/org/dromara/sis/rocketmq/consumer/MeterRecordConsumer.java
View File

@@ -1,44 +1,44 @@
package org.dromara.sis.rocketmq.consumer; //package org.dromara.sis.rocketmq.consumer;
//
import lombok.RequiredArgsConstructor; //import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; //import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.common.message.MessageExt; //import org.apache.rocketmq.common.message.MessageExt;
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.dromara.sis.rocketmq.RocketMqConstants; //import org.dromara.sis.rocketmq.RocketMqConstants;
import org.dromara.sis.rocketmq.producer.ProducerService; //import org.dromara.sis.rocketmq.producer.ProducerService;
import org.springframework.stereotype.Component; //import org.springframework.stereotype.Component;
//
/** ///**
* @author lsm // * @author lsm
* @apiNote MeterRecordConsumer // * @apiNote MeterRecordConsumer
* @since 2025/8/25 // * @since 2025/8/25
*/ // */
@Slf4j //@Slf4j
@Component //@Component
@RequiredArgsConstructor //@RequiredArgsConstructor
@RocketMQMessageListener( //@RocketMQMessageListener(
topic = RocketMqConstants.TOPIC, // topic = RocketMqConstants.TOPIC,
consumerGroup = RocketMqConstants.METER_GROUP, // consumerGroup = RocketMqConstants.METER_GROUP,
selectorExpression = RocketMqConstants.METER_RECORD, // selectorExpression = RocketMqConstants.METER_RECORD,
nameServer = "${rocketmq.cluster1.name-server}" // nameServer = "${rocketmq.cluster1.name-server}"
) //)
public class MeterRecordConsumer implements RocketMQListener<MessageExt> { //public class MeterRecordConsumer implements RocketMQListener<MessageExt> {
//
private final ProducerService producerService; // private final ProducerService producerService;
//
@Override // @Override
public void onMessage(MessageExt ext) { // public void onMessage(MessageExt ext) {
try { // try {
if (ext.getBody() == null) { // if (ext.getBody() == null) {
log.info("仪表上报消息数据，不转发！"); // log.info("仪表上报消息数据，不转发！");
} else { // } else {
producerService.defaultSend(RocketMqConstants.TOPIC, RocketMqConstants.METER_RECORD, new String(ext.getBody())); // producerService.defaultSend(RocketMqConstants.TOPIC, RocketMqConstants.METER_RECORD, new String(ext.getBody()));
log.info("转发仪表上报数据处理成功"); // log.info("转发仪表上报数据处理成功");
} // }
} catch (Exception e) { // } catch (Exception e) {
log.error("转发仪表上报数据处理失败，", e); // log.error("转发仪表上报数据处理失败，", e);
} // }
//
} // }
} //}