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
index 42542210e5..2966062c56 100644
--- 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 abstract class AbstractPluginMessageStore implements MessageStore {
         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();