From fb026867f81b127b6b620ae29abb4f057f004aea Mon Sep 17 00:00:00 2001
From: RongtongJin <jinrongtong16@mails.ucas.ac.cn>
Date: Tue, 12 Jul 2022 14:28:47 +0800
Subject: [PATCH] Add missing override method in AbstractPluginMessageStore

---
 .../rocketmq/broker/plugin/AbstractPluginMessageStore.java    | 4 ++++
 1 file changed, 4 insertions(+)

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();