代码优化

yangys

2024-05-18 cc0bdfb33ef638dfafe3185c92c7076d815e1c9b

 smart-man-boot/src/main/java/com/qianwen/smartman/modules/cps/message/consumer/TelemetryDataRealTimeConsumer.java

@@ -26,6 +26,9 @@
import com.qianwen.smartman.modules.cps.utils.TelemetryDataUtils;
import org.springframework.stereotype.Component;

/**
 * rockmq消息消费者 telemetry(遥测)
 */
@RocketMQMessageListener(topic = "telemetry-data", consumerGroup = "telemetry-data-real-time-consumer", consumeMode = ConsumeMode.ORDERLY)
@Component
public class TelemetryDataRealTimeConsumer implements RocketMQListener<TelemetryDataMessage>, RocketMQPushConsumerLifecycleListener {
@@ -60,10 +63,12 @@
            });
        }
    }

    @Override
    public void prepareStart(DefaultMQPushConsumer consumer) {
        consumer.setMaxReconsumeTimes(1);
        consumer.setInstanceName(CommonUtil.changeInstanceNameToPID(consumer));
        consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);
    }

	
}