RocketMQ源码分析之消息重试

当消息消费失败后须要把消息从新发送给broker，能够设置延迟级别java public boolean sendMessageBack(final MessageExt msg, final ConsumeConcurrentlyContext context) { int delayLevel = context.getDelayLevelWhenNextConsume();

>>阅读原文<<