| | |
|---|
| | | package com.ruoyi.integration.rocket.listener; |
|---|
| | | |
|---|
| | | import com.ruoyi.integration.api.model.Online; |
|---|
| | | import com.ruoyi.integration.api.model.Ping; |
|---|
| | | import com.ruoyi.integration.api.model.Pong; |
|---|
| | | 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.mongodb.service.PingService; |
|---|
| | | import com.ruoyi.integration.rocket.model.OnlineMessage; |
|---|
| | | import com.ruoyi.integration.rocket.model.PingMessage; |
|---|
| | | import com.ruoyi.integration.rocket.util.EnhanceMessageHandler; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.apache.rocketmq.client.consumer.listener.MessageListener; |
|---|
| | | import org.apache.rocketmq.spring.annotation.MessageModel; |
|---|
| | | import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; |
|---|
| | | import org.apache.rocketmq.spring.core.RocketMQListener; |
|---|
