Skip to content

Commit e4170f5

Browse files
authored
Add timestamp query message offset to abstract class (#9836)
Change-Id: I78091629c0b3f7ac438a82aa326a76970e1a80df Signed-off-by: terrance.lzm <[email protected]>
1 parent 29a62c4 commit e4170f5

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

store/src/main/java/org/apache/rocketmq/store/plugin/AbstractPluginMessageStore.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
import java.util.Set;
2929
import java.util.concurrent.CompletableFuture;
3030
import java.util.function.Supplier;
31+
import org.apache.rocketmq.common.BoundaryType;
3132
import org.apache.rocketmq.common.Pair;
3233
import org.apache.rocketmq.common.SystemClock;
3334
import org.apache.rocketmq.common.message.MessageExt;
@@ -165,6 +166,11 @@ public long getOffsetInQueueByTime(String topic, int queueId, long timestamp) {
165166
return next.getOffsetInQueueByTime(topic, queueId, timestamp);
166167
}
167168

169+
@Override
170+
public long getOffsetInQueueByTime(String topic, int queueId, long timestamp, BoundaryType boundaryType) {
171+
return next.getOffsetInQueueByTime(topic, queueId, timestamp, boundaryType);
172+
}
173+
168174
@Override
169175
public MessageExt lookMessageByOffset(long commitLogOffset) {
170176
return next.lookMessageByOffset(commitLogOffset);

0 commit comments

Comments
 (0)