|
|
@ -128,7 +128,7 @@ public abstract class EnhanceMessageHandler<T extends BaseMessage> { |
|
|
IPersist persist = repeatConsumerConfig.getPersist(); |
|
|
IPersist persist = repeatConsumerConfig.getPersist(); |
|
|
RepeatElement repeatElement = new RepeatElement(repeatConsumerConfig.getApplicationName(), message.getConsumerGroupName(),message.getTopic() |
|
|
RepeatElement repeatElement = new RepeatElement(repeatConsumerConfig.getApplicationName(), message.getConsumerGroupName(),message.getTopic() |
|
|
, message.getTag()==null ? "" : message.getTag() |
|
|
, message.getTag()==null ? "" : message.getTag() |
|
|
, this.repeatMessageKey(message)); |
|
|
, repeatMessageKey(message)); |
|
|
//消费消息,末尾消费失败会删除消费记录,消费成功则更新消费状态
|
|
|
//消费消息,末尾消费失败会删除消费记录,消费成功则更新消费状态
|
|
|
try { |
|
|
try { |
|
|
long now = System.currentTimeMillis(); |
|
|
long now = System.currentTimeMillis(); |
|
|
|