wordpress响应式网站模板,电商网站建设合同,安慧桥做网站公司,天津网站优化指导RocketMQ实现延时消费 rocketMQTemplate.syncSend(“helloTopicBoot”,msg,3000,3); 3000为等待消息回传时间#xff0c;如果3000毫秒还没有回传即发送错误信息#xff0c; 3为延时消费的时间 /***生产者*发送延时消息*/Testpublic void sendDelayMsg(){Message msg Message…RocketMQ实现延时消费 rocketMQTemplate.syncSend(“helloTopicBoot”,msg,3000,3); 3000为等待消息回传时间如果3000毫秒还没有回传即发送错误信息 3为延时消费的时间 /***生产者*发送延时消息*/Testpublic void sendDelayMsg(){Message msg MessageBuilder.withPayload(发送延时消息发送时间new Date()).build();rocketMQTemplate.syncSend(helloTopicBoot,msg,3000,3);}/***消费者*不需要添加任何东西只是打印出来便于观察*/
Component
RocketMQMessageListener(consumerGroup htpConsumerGroup,topic helloTopicBoot,messageModel MessageModel.BROADCASTING)
public class HelloTopicListener implements RocketMQListenerMessageExt {Overridepublic void onMessage(MessageExt messageExt) {System.out.println(消费时间new Date() 收到的消息:new String(messageExt.getBody(), Charset.defaultCharset()));}
}
