Add missing override method in AbstractPluginMessageStore

apache · Jul 12, 2022 · fb02686 · fb02686
1 parent 69b74d2
commit fb02686
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/plugin/AbstractPluginMessageStore.java b/broker/src/main/java/org/apache/rocketmq/broker/plugin/AbstractPluginMessageStore.java
@@ -276,6 +276,10 @@ public ConsumeQueueInterface getConsumeQueue(String topic, int queueId) {
         return next.getConsumeQueue(topic, queueId);
     }
 
+    @Override public ConsumeQueueInterface findConsumeQueue(String topic, int queueId) {
+        return next.findConsumeQueue(topic, queueId);
+    }
+
     @Override
     public BrokerStatsManager getBrokerStatsManager() {
         return next.getBrokerStatsManager();