Browse Source

优化

feature-1.1
wuxicheng 3 years ago
parent
commit
0cdfa32ff4
  1. 6
      bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/strategy/RedisRepeatStrategy.java

6
bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/strategy/RedisRepeatStrategy.java

@ -44,9 +44,9 @@ public class RedisRepeatStrategy implements RepeatConsumerStrategy {
private <T extends BaseMessage> boolean doInvoke(T message) {
IPersist persist = repeatConfig.getPersist();
//RepeatElement repeatElement = new RepeatElement(repeatConfig.getApplicationName(), message.getConsumerGroupName(),message.getTopic()
// , message.getTag()==null ? "" : message.getTag()
// , repeatMessageKeyFunction.apply(message));
RepeatElement repeatElement = new RepeatElement(repeatConfig.getApplicationName(), message.getConsumerGroupName(),message.getTopic()
, message.getTag()==null ? "" : message.getTag()
, repeatMessageKeyFunction.apply(message));
boolean shouldConsume = true;
if (StringUtils.isNotBlank(repeatElement.getMessageKey())) {
shouldConsume = persist.setConsumingIfNX(repeatElement, repeatConfig.getProcessingExpireMilliSeconds());

Loading…
Cancel
Save