Skip to content

Commit 1d4ca6b

Browse files
authored
[clean code] clean unused method: getRangeConsumer (#13775)
1 parent 0cdcf51 commit 1d4ca6b

File tree

2 files changed

+0
-10
lines changed

2 files changed

+0
-10
lines changed

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsistentHashingStickyKeyConsumerSelector.java

-5
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020

2121
import com.google.common.collect.Lists;
2222
import java.util.ArrayList;
23-
import java.util.Collections;
2423
import java.util.Comparator;
2524
import java.util.LinkedHashMap;
2625
import java.util.List;
@@ -144,8 +143,4 @@ public Map<Consumer, List<Range>> getConsumerKeyHashRanges() {
144143
}
145144
return result;
146145
}
147-
148-
Map<Integer, List<Consumer>> getRangeConsumer() {
149-
return Collections.unmodifiableMap(hashRing);
150-
}
151146
}

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeAutoSplitStickyKeyConsumerSelector.java

-5
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@
1919
package org.apache.pulsar.broker.service;
2020

2121
import java.util.ArrayList;
22-
import java.util.Collections;
2322
import java.util.HashMap;
2423
import java.util.List;
2524
import java.util.Map;
@@ -160,8 +159,4 @@ private boolean is2Power(int num) {
160159
}
161160
return (num & num - 1) == 0;
162161
}
163-
164-
Map<Integer, Consumer> getRangeConsumer() {
165-
return Collections.unmodifiableMap(rangeMap);
166-
}
167162
}

0 commit comments

Comments
 (0)