Skip to content

Commit f56cea9

Browse files
committed
fix
1 parent 4e9574a commit f56cea9

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStoreInterface.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,12 @@ public interface ConsumeQueueStoreInterface {
3838
*/
3939
void recover(boolean concurrently) throws RocksDBException;
4040

41+
/**
42+
* Get the dispatch offset in consume queue store, messages whose phyOffset larger than this offset need
43+
* to be dispatched. The dispatch offset only used in recover.
44+
*
45+
* @return the dispatch phyOffset
46+
*/
4147
long getDispatchFromPhyOffset();
4248

4349
/**

0 commit comments

Comments
 (0)