diff --git a/store/src/main/java/org/apache/rocketmq/store/plugin/AbstractPluginMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/plugin/AbstractPluginMessageStore.java index 673f045bf7..33908df862 100644 --- a/store/src/main/java/org/apache/rocketmq/store/plugin/AbstractPluginMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/plugin/AbstractPluginMessageStore.java @@ -28,6 +28,7 @@ import java.util.List; import java.util.Set; import java.util.concurrent.CompletableFuture; import java.util.function.Supplier; +import org.apache.rocketmq.common.BoundaryType; import org.apache.rocketmq.common.Pair; import org.apache.rocketmq.common.SystemClock; import org.apache.rocketmq.common.message.MessageExt; @@ -165,6 +166,11 @@ public abstract class AbstractPluginMessageStore implements MessageStore { return next.getOffsetInQueueByTime(topic, queueId, timestamp); } + @Override + public long getOffsetInQueueByTime(String topic, int queueId, long timestamp, BoundaryType boundaryType) { + return next.getOffsetInQueueByTime(topic, queueId, timestamp, boundaryType); + } + @Override public MessageExt lookMessageByOffset(long commitLogOffset) { return next.lookMessageByOffset(commitLogOffset);