| | |
|---|
| | | package com.ruoyi.integration.rocket.listener; |
|---|
| | | |
|---|
| | | import com.ruoyi.integration.api.model.Online; |
|---|
| | | import com.ruoyi.integration.api.model.OnlineReply; |
|---|
| | | import com.ruoyi.integration.iotda.enums.ServiceIdMenu; |
|---|
| | | import com.ruoyi.integration.iotda.utils.produce.IotMessageProduce; |
|---|
| | | import com.ruoyi.integration.iotda.utils.tools.MessageUtil; |
|---|
| | | import com.ruoyi.integration.mongodb.service.OnlineService; |
|---|
| | | import com.ruoyi.integration.rocket.model.OnlineMessage; |
|---|
| | | import com.ruoyi.integration.rocket.model.OnlineMessage; |
|---|
| | | 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( |
|---|
| | | messageModel = MessageModel.CLUSTERING, |
|---|
| | | consumerGroup = "charge_online", |
|---|
| | | topic = "charge_online", |
|---|
| | | selectorExpression = "online", // 明确指定标签 |
|---|
