Add missing override method in AbstractPluginMessageStore

2026-09-21 05:44:03 +08:00 · 2022-07-12 14:28:47 +08:00
parent 69b74d2456
commit fb026867f8
1 changed files with 4 additions and 0 deletions
@@ -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();