rocketmq cluster下concurrently重試機制實現

整體來講比較迂迴,比較巧妙地利用了原順序存儲機制和delay隊列機制.java 重試消息的consumer發回: spa       ConsumeMessageConcurrentlyService.java 裏     processConsumeResult(ConsumeConcurrentlyStatus, ConsumeConcurrentlyContext, ConsumeReque

>>阅读原文<<