| | |
|---|
| | | |
|---|
| | | @RocketMQMessageListener(topic = "telemetry-data", consumerGroup = "telemetry-data-real-time-consumer", consumeMode = ConsumeMode.ORDERLY) |
|---|
| | | @Component |
|---|
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/cps/message/consumer/TelemetryDataRealTimeConsumer.class */ |
|---|
| | | public class TelemetryDataRealTimeConsumer implements RocketMQListener<TelemetryDataMessage>, RocketMQPushConsumerLifecycleListener { |
|---|
| | | private static final Logger log = LoggerFactory.getLogger(TelemetryDataRealTimeConsumer.class); |
|---|
| | | |
|---|
