RocketMQ源碼分析之消息重試

當消息消費失敗後須要把消息從新發送給broker，能夠設置延遲級別java public boolean sendMessageBack(final MessageExt msg, final ConsumeConcurrentlyContext context) { int delayLevel = context.getDelayLevelWhenNextConsume();

>>阅读原文<<