通过设置rondom=1来使主题其他broker也可以拉到重试队列消息

jd-opensource · Sep 6, 2020 · 7d771cb · 7d771cb
1 parent dcf7feb
commit 7d771cb
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/.../joyqueue-broker-core/src/main/java/org/joyqueue/broker/consumer/CasPartitionManager.java b/.../joyqueue-broker-core/src/main/java/org/joyqueue/broker/consumer/CasPartitionManager.java
@@ -223,10 +223,20 @@ public boolean isRetry(Consumer consumer) throws JoyQueueException {
 
         Boolean retry = clusterManager.getConsumerPolicy(TopicName.parse(consumer.getTopic()), consumer.getApp()).getRetry();
         List<Short> masterPartitionList = clusterManager.getLocalPartitions(TopicName.parse(consumer.getTopic()));
-        if (!retry.booleanValue() || !masterPartitionList.contains((short) 0)) {
+
+        if (!retry) {
             logger.debug("retry enable is false.");
             return false;
         }
+        if (randomBound == 1) {
+            return true;
+        } else if (!masterPartitionList.contains((short) 0)) {
+            return false;
+        }
+        /*if (!retry.booleanValue() || !masterPartitionList.contains((short) 0)) {
+            logger.debug("retry enable is false.");
+            return false;
+        }*/
 
         int val = random.nextInt(randomBound);
         // 重试管理中获取从重试分区消费的概率