diff --git a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java index 9d56c4a8daa..138cb3435bd 100644 --- a/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java +++ b/tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java @@ -330,6 +330,11 @@ public CompletableFuture getEarliestMessageTimeAsync(String topic, int que }); } + @Override + public long getMessageStoreTimeStamp(String topic, int queueId, long consumeQueueOffset) { + return getMessageStoreTimeStampAsync(topic, queueId, consumeQueueOffset).join(); + } + @Override public CompletableFuture getMessageStoreTimeStampAsync(String topic, int queueId, long consumeQueueOffset) {