yanglin2000168 opened a new issue #13: 在阿里云服务器部署rocketmq 4.2.0用于生产环境，每一次重启consumer所在服务器，出现将之前订阅过消息全部重新发送一次 URL: https://github.com/apache/rocketmq-spring/issues/13 @RocketMQMessageListener(topic = RocketmqTopics.EMAIL, consumerGroup = RocketmqTopics.EMAIL_CONSUMER) public class EmailRocketMQServiceImpl implements RocketMQListener<MailParam> { public void onMessage(String msgId,MailParam mailParam) { } }
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
