(rocketmq) branch develop updated: Add timestamp query message offset to abstract class (#9836)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new e4170f561c Add timestamp query message offset to abstract class (#9836)
e4170f561c is described below

commit e4170f561c9dbd87482d3b0fe7588a566ff3c73c
Author: lizhimins <707364...@qq.com>
AuthorDate: Tue Nov 11 15:23:22 2025 +0800

    Add timestamp query message offset to abstract class (#9836)
    
    Change-Id: I78091629c0b3f7ac438a82aa326a76970e1a80df
    
    Signed-off-by: terrance.lzm <terrance....@alibaba-inc.com>
---
 .../apache/rocketmq/store/plugin/AbstractPluginMessageStore.java    | 6 ++++++
 1 file changed, 6 insertions(+)

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