| | |
|---|
| | | import com.ruoyi.integration.rocket.model.TimingSettingMessage; |
|---|
| | | import com.ruoyi.integration.rocket.util.EnhanceMessageHandler; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.apache.rocketmq.spring.annotation.MessageModel; |
|---|
| | | import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; |
|---|
| | | import org.apache.rocketmq.spring.core.RocketMQListener; |
|---|
| | | import org.springframework.beans.BeanUtils; |
|---|
| | |
|---|
| | | @Slf4j |
|---|
| | | @Component |
|---|
| | | @RocketMQMessageListener( |
|---|
| | | consumerGroup = "enhance_consumer_group", |
|---|
| | | topic = "rocket_enhance", |
|---|
| | | selectorExpression = "*", |
|---|
| | | messageModel = MessageModel.CLUSTERING, |
|---|
| | | consumerGroup = "charge_timing_setting", |
|---|
| | | topic = "charge_timing_setting", |
|---|
| | | selectorExpression = "timing_setting", |
|---|
| | | consumeThreadMax = 5 //默认是64个线程并发消息，配置 consumeThreadMax 参数指定并发消费线程数，避免太大导致资源不够 |
|---|
| | | ) |
|---|
| | | public class TimingSettingMessageListener extends EnhanceMessageHandler<TimingSettingMessage> implements RocketMQListener<TimingSettingMessage> { |
|---|
| | |
|---|
| | | TimingSetting timingSetting = new TimingSetting(); |
|---|
| | | BeanUtils.copyProperties(message,timingSetting); |
|---|
| | | timingSettingService.create(timingSetting); |
|---|
| | | // 业务处理 对时设置应答 |
|---|
| | | TimingSettingReply timingSettingReply = new TimingSettingReply(); |
|---|
| | | timingSettingReply.setCharging_pile_code(message.getCharging_pile_code()); |
|---|
| | | timingSettingReply.setCurrent_time(CP56Time2aConverter.convertToCP56Time2a(new Date())); |
|---|
| | | iotMessageProduce.sendMessage(timingSettingReply.getCharging_pile_code(), ServiceIdMenu.TIMING_SETTING_REPLY.getKey(),messageUtil.timingSettingReply(timingSettingReply)); |
|---|
| | | // 业务处理 |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
