Skip to content

Commit f74565c

Browse files
author
RongtongJin
committed
remove implementation
1 parent 6bf661a commit f74565c

1 file changed

Lines changed: 0 additions & 6 deletions

File tree

store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -172,12 +172,6 @@ public boolean shutdown() {
172172
return false;
173173
}
174174

175-
for (Map.Entry<String, ConcurrentMap<Integer, ConsumeQueueInterface>> topicEntry : this.consumeQueueTable.entrySet()) {
176-
for (Map.Entry<Integer, ConsumeQueueInterface> cqEntry : topicEntry.getValue().entrySet()) {
177-
cqEntry.getValue().shutdown();
178-
}
179-
}
180-
181175
return true;
182176
}
183177

0 commit comments

Comments
 (0)